org.mule.providers.tcp
Class TcpConnector

java.lang.Object
  extended byorg.mule.providers.AbstractConnector
      extended byorg.mule.providers.AbstractServiceEnabledConnector
          extended byorg.mule.providers.tcp.TcpConnector
All Implemented Interfaces:
Disposable, ExceptionListener, Initialisable, UMOConnectable, UMOConnector
Direct Known Subclasses:
HttpConnector, SslConnector

public class TcpConnector
extends AbstractServiceEnabledConnector

TcpConnector can bind or sent to a given tcp port on a given host.

Version:
$Revision: 3798 $
Author:
Ross Mason, P.Oikari

Field Summary
protected  int backlog
           
protected  int bufferSize
           
static int DEFAULT_BACKLOG
           
static int DEFAULT_BUFFER_SIZE
           
static int DEFAULT_SOCKET_TIMEOUT
           
protected  boolean keepAlive
           
protected  boolean keepSendSocketOpen
           
protected  int receiveTimeout
           
protected  int sendTimeout
           
protected  TcpProtocol tcpProtocol
           
protected  String tcpProtocolClassName
           
 
Fields inherited from class org.mule.providers.AbstractServiceEnabledConnector
serviceDescriptor, serviceOverrides
 
Fields inherited from class org.mule.providers.AbstractConnector
connected, connecting, createDispatcherPerRequest, createMultipleTransactedReceivers, defaultInboundTransformer, defaultOutboundTransformer, defaultResponseTransformer, dispatcherFactory, dispatchers, disposed, disposing, exceptionListener, initialised, logger, name, receivers, serverSide, sessionHandler, started, startOnConnect
 
Fields inherited from interface org.mule.umo.provider.UMOConnector
INT_VALUE_NOT_SET
 
Constructor Summary
TcpConnector()
           
 
Method Summary
 void doInitialise()
           
 int getBacklog()
           
 int getBufferSize()
           
 String getProtocol()
           
 int getReceiveTimeout()
           
 int getSendTimeout()
           
 TcpProtocol getTcpProtocol()
           
 String getTcpProtocolClassName()
           
 boolean isKeepAlive()
           
 boolean isKeepSendSocketOpen()
           
 boolean isRemoteSyncEnabled()
           
 void setBacklog(int backlog)
           
 void setBufferSize(int bufferSize)
           
 void setKeepAlive(boolean keepAlive)
           
 void setReceiveTimeout(int timeout)
           
 void setSendTimeout(int timeout)
           
 void setTcpProtocol(TcpProtocol tcpProtocol)
           
 void setTcpProtocolClassName(String protocolClassName)
           
 void setTimeout(int timeout)
          A shorthand property setting timeout for both SEND and RECEIVE sockets.
 
Methods inherited from class org.mule.providers.AbstractServiceEnabledConnector
createReceiver, getMessageAdapter, getServiceDescriptor, getServiceOverrides, getStreamMessageAdapter, initFromServiceDescriptor, initialiseFromUrl, setServiceOverrides
 
Methods inherited from class org.mule.providers.AbstractConnector
checkDisposed, connect, createDispatcher, destroyReceiver, disconnect, dispose, disposeDispatchers, disposeReceivers, doConnect, doDisconnect, doDispose, doStart, doStop, exceptionThrown, fireNotification, getConnectEventId, getConnectionDescription, getConnectionStrategy, getDefaultInboundTransformer, getDefaultOutboundTransformer, getDefaultResponseTransformer, getDispatcher, getDispatcher, getDispatcherFactory, getDispatchers, getDispatcherThreadingProfile, getExceptionListener, getName, getReceiver, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReplyToHandler, getSessionHandler, getSupportedProtocols, handleException, handleWorkException, initialise, isConnected, isCreateDispatcherPerRequest, isCreateMultipleTransactedReceivers, isDisposed, isDisposing, isEnableMessageEvents, isServerSide, isStarted, isUseSingleDispatcherThreadPool, isUseSingleReceiverThreadPool, lookupDispatcher, lookupReceiver, registerListener, registerSupportedProtocol, registerSupportedProtocolWithotPrefix, setConnectionStrategy, setCreateDispatcherPerRequest, setCreateMultipleTransactedReceivers, setDefaultInboundTransformer, setDefaultOutboundTransformer, setDefaultResponseTransformer, setDispatcherFactory, setDispatcherThreadingProfile, setEnableMessageEvents, setExceptionListener, setName, setReceiverThreadingProfile, setServerSide, setSessionHandler, setSupportedProtocols, setUseSingleDispatcherThreadPool, setUseSingleReceiverThreadPool, startConnector, stopConnector, supportsProtocol, unregisterListener, unregisterSupportedProtocol, workAccepted, workCompleted, workRejected, workStarted
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

DEFAULT_SOCKET_TIMEOUT

public static final int DEFAULT_SOCKET_TIMEOUT
See Also:
Constant Field Values

DEFAULT_BUFFER_SIZE

public static final int DEFAULT_BUFFER_SIZE
See Also:
Constant Field Values

DEFAULT_BACKLOG

public static final int DEFAULT_BACKLOG
See Also:
Constant Field Values

sendTimeout

protected int sendTimeout

receiveTimeout

protected int receiveTimeout

bufferSize

protected int bufferSize

backlog

protected int backlog

tcpProtocolClassName

protected String tcpProtocolClassName

tcpProtocol

protected TcpProtocol tcpProtocol

keepSendSocketOpen

protected boolean keepSendSocketOpen

keepAlive

protected boolean keepAlive
Constructor Detail

TcpConnector

public TcpConnector()
Method Detail

isKeepSendSocketOpen

public boolean isKeepSendSocketOpen()

doInitialise

public void doInitialise()
                  throws InitialisationException
Overrides:
doInitialise in class AbstractServiceEnabledConnector
Throws:
InitialisationException

getProtocol

public String getProtocol()
Specified by:
getProtocol in interface UMOConnector
Specified by:
getProtocol in class AbstractConnector

setTimeout

public void setTimeout(int timeout)
A shorthand property setting timeout for both SEND and RECEIVE sockets.


getSendTimeout

public int getSendTimeout()

setSendTimeout

public void setSendTimeout(int timeout)

getReceiveTimeout

public int getReceiveTimeout()

setReceiveTimeout

public void setReceiveTimeout(int timeout)

getBufferSize

public int getBufferSize()

setBufferSize

public void setBufferSize(int bufferSize)

getBacklog

public int getBacklog()

setBacklog

public void setBacklog(int backlog)

getTcpProtocol

public TcpProtocol getTcpProtocol()

setTcpProtocol

public void setTcpProtocol(TcpProtocol tcpProtocol)

getTcpProtocolClassName

public String getTcpProtocolClassName()

setTcpProtocolClassName

public void setTcpProtocolClassName(String protocolClassName)

isRemoteSyncEnabled

public boolean isRemoteSyncEnabled()
Specified by:
isRemoteSyncEnabled in interface UMOConnector
Overrides:
isRemoteSyncEnabled in class AbstractConnector

isKeepAlive

public boolean isKeepAlive()

setKeepAlive

public void setKeepAlive(boolean keepAlive)


Copyright © 2003-2006 MuleSource Inc.. All Rights Reserved.