org.mule.providers.tcp
Class TcpMessageReceiver

java.lang.Object
  extended byorg.mule.providers.AbstractMessageReceiver
      extended byorg.mule.providers.tcp.TcpMessageReceiver
All Implemented Interfaces:
Disposable, java.lang.Runnable, UMOMessageReceiver
Direct Known Subclasses:
HttpMessageReceiver, SslMessageReceiver

public class TcpMessageReceiver
extends AbstractMessageReceiver
implements java.lang.Runnable

TcpMessageReceiver acts like a tcp server to receive socket requests.

Version:
$Revision: 1.5 $
Author:
Ross Mason

Nested Class Summary
protected  class TcpMessageReceiver.TcpWorker
           
 
Field Summary
 
Fields inherited from class org.mule.providers.AbstractMessageReceiver
component, connector, disposing, endpoint, logger, model, serverSide
 
Constructor Summary
TcpMessageReceiver(AbstractConnector connector, UMOComponent component, UMOEndpoint endpoint)
           
 
Method Summary
protected  void connect(java.net.URI uri)
           
protected  java.net.ServerSocket createSocket(java.net.URI uri)
           
protected  java.lang.Runnable createWorker(java.net.Socket socket)
           
 void doDispose()
          Template method to dispose any resources associated with this receiver.
 java.net.ServerSocket getServerSocket()
          Obtain the serverSocket
protected  ThreadFactory getThreadFactory()
           
 void run()
           
 
Methods inherited from class org.mule.providers.AbstractMessageReceiver
allowFilter, create, dispose, getComponent, getConnector, getEndpoint, getEndpointURI, handleException, handleSecurtyException, handleUnacceptedFilter, isServerSide, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setComponent, setConnector, setEndpoint, setServerSide
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TcpMessageReceiver

public TcpMessageReceiver(AbstractConnector connector,
                          UMOComponent component,
                          UMOEndpoint endpoint)
                   throws InitialisationException
Method Detail

getThreadFactory

protected ThreadFactory getThreadFactory()

connect

protected void connect(java.net.URI uri)
                throws InitialisationException
Throws:
InitialisationException

createSocket

protected java.net.ServerSocket createSocket(java.net.URI uri)
                                      throws java.lang.Exception
Throws:
java.lang.Exception

getServerSocket

public java.net.ServerSocket getServerSocket()
Obtain the serverSocket


run

public void run()
Specified by:
run in interface java.lang.Runnable

doDispose

public void doDispose()
               throws UMOException
Description copied from class: AbstractMessageReceiver
Template method to dispose any resources associated with this receiver. There is not need to dispose the connector as this is already done by the framework

Overrides:
doDispose in class AbstractMessageReceiver
Throws:
UMOException

createWorker

protected java.lang.Runnable createWorker(java.net.Socket socket)


Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.