org.mule.providers.tcp
Class TcpConnector
java.lang.Object
org.mule.providers.AbstractConnector
org.mule.providers.AbstractServiceEnabledConnector
org.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
| 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 |
| 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 |
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
TcpConnector
public TcpConnector()
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.