org.mule.providers.tcp
Class TcpMessageReceiver.TcpWorker

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

protected class TcpMessageReceiver.TcpWorker
extends Object
implements Disposable


Field Summary
protected  AtomicBoolean closed
           
protected  DataInputStream dataIn
           
protected  DataOutputStream dataOut
           
protected  TcpProtocol protocol
           
protected  Socket socket
           
 
Constructor Summary
TcpMessageReceiver.TcpWorker(Socket socket)
           
 
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
 

Field Detail

socket

protected Socket socket

dataIn

protected DataInputStream dataIn

dataOut

protected DataOutputStream dataOut

closed

protected AtomicBoolean closed

protocol

protected TcpProtocol protocol
Constructor Detail

TcpMessageReceiver.TcpWorker

public TcpMessageReceiver.TcpWorker(Socket socket)
Method Detail

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.