org.mule.providers.tcp
Class TcpMessageReceiver
java.lang.Object
org.mule.providers.AbstractMessageReceiver
org.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
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 |
TcpMessageReceiver
public TcpMessageReceiver(AbstractConnector connector,
UMOComponent component,
UMOEndpoint endpoint)
throws InitialisationException
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.