org.mule.providers.tcp
Class TcpMessageReceiver.TcpWorker

java.lang.Object
  extended byorg.mule.providers.tcp.TcpMessageReceiver.TcpWorker
All Implemented Interfaces:
Disposable, java.lang.Runnable
Enclosing class:
TcpMessageReceiver

protected class TcpMessageReceiver.TcpWorker
extends java.lang.Object
implements java.lang.Runnable, Disposable


Field Summary
protected  SynchronizedBoolean closed
           
protected  java.io.DataInputStream dataIn
           
protected  java.io.DataOutputStream dataOut
           
protected  java.net.Socket socket
           
 
Constructor Summary
TcpMessageReceiver.TcpWorker(java.net.Socket socket)
           
 
Method Summary
 void dispose()
           
protected  byte[] processData(byte[] data)
           
 void run()
          Accept requests from a given TCP port
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

socket

protected java.net.Socket socket

dataIn

protected java.io.DataInputStream dataIn

dataOut

protected java.io.DataOutputStream dataOut

closed

protected SynchronizedBoolean closed
Constructor Detail

TcpMessageReceiver.TcpWorker

public TcpMessageReceiver.TcpWorker(java.net.Socket socket)
Method Detail

dispose

public void dispose()
Specified by:
dispose in interface Disposable

run

public void run()
Accept requests from a given TCP port

Specified by:
run in interface java.lang.Runnable

processData

protected byte[] processData(byte[] data)
                      throws java.lang.Exception
Throws:
java.lang.Exception


Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.