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 Object
- implements Disposable
|
Method Summary |
void |
dispose()
A lifecycle method where implementor should free up any resources. |
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 Socket socket
dataIn
protected DataInputStream dataIn
dataOut
protected DataOutputStream dataOut
closed
protected AtomicBoolean closed
protocol
protected TcpProtocol protocol
TcpMessageReceiver.TcpWorker
public TcpMessageReceiver.TcpWorker(Socket socket)
release
public void release()
dispose
public void dispose()
- Description copied from interface:
Disposable
- A lifecycle method where implementor should free 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 Exception
- Throws:
Exception
Copyright © 2003-2006 MuleSource Inc.. All Rights Reserved.