org.mule.providers.tcp
Class TcpMessageReceiver.TcpWorker
java.lang.Object
org.mule.providers.tcp.TcpMessageReceiver.TcpWorker
- All Implemented Interfaces:
- Disposable
- Enclosing class:
- TcpMessageReceiver
- protected class TcpMessageReceiver.TcpWorker
- extends java.lang.Object
- implements 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()
A lifecycle method where implementor should fee up any resources
If an exception is thrown it should just be logged and processing should
continue. |
protected byte[] |
processData(byte[] data)
|
void |
release()
|
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)
release
public void release()
dispose
public void dispose()
- Description copied from interface:
Disposable
- A lifecycle method where implementor should fee up any resources
If an exception is thrown it should just be logged and processing should
continue. This method should not throw Runtime exceptions
- Specified by:
dispose
in interface Disposable
run
public void run()
- Accept requests from a given TCP port
processData
protected byte[] processData(byte[] data)
throws java.lang.Exception
- Throws:
java.lang.Exception
Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.