org.mule.providers.tcp
Class TcpMessageReceiver.TcpWorker
java.lang.Object
org.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
|
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 |
socket
protected java.net.Socket socket
dataIn
protected java.io.DataInputStream dataIn
dataOut
protected java.io.DataOutputStream dataOut
closed
protected SynchronizedBoolean closed
TcpMessageReceiver.TcpWorker
public TcpMessageReceiver.TcpWorker(java.net.Socket socket)
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.