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 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
           
 
Constructor Summary
TcpMessageReceiver.TcpWorker(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
 

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

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.