public class TcpNetClientConnectionFactory extends AbstractClientConnectionFactory
TcpNetConnections.DEFAULT_REPLY_TIMEOUT, lifecycleMonitorEXPRESSION_PARSER, logger| Constructor and Description |
|---|
TcpNetClientConnectionFactory(String host,
int port)
Creates a TcpNetClientConnectionFactory for connections to the host and port.
|
| Modifier and Type | Method and Description |
|---|---|
protected TcpConnectionSupport |
buildNewConnection() |
protected Socket |
createSocket(String host,
int port)
Create a new
Socket. |
protected TcpSocketFactorySupport |
getTcpSocketFactorySupport() |
void |
setTcpNetConnectionSupport(TcpNetConnectionSupport connectionSupport)
Set the
TcpNetConnectionSupport to use to create connection objects. |
void |
setTcpSocketFactorySupport(TcpSocketFactorySupport tcpSocketFactorySupport) |
void |
start() |
enableManualListenerRegistration, forceClose, getConnection, getConnectionTest, getConnectTimeout, getTheConnection, initializeConnection, obtainConnection, obtainNewConnection, obtainSharedConnection, setConnectionTest, setConnectTimeout, setTheConnectionaddConnection, checkActive, closeConnection, delayRead, doAccept, getApplicationEventPublisher, getDelayedReads, getDeserializer, getHost, getLifecycleMonitor, getListener, getMapper, getOpenConnectionIds, getPort, getReadDelay, getSender, getSenders, getSerializer, getSoLinger, getSoReceiveBufferSize, getSoSendBufferSize, getSoTimeout, getSoTrafficClass, getSslHandshakeTimeout, getTaskExecutor, getTcpSocketSupport, harvestClosedConnections, isActive, isLookupHost, isRunning, isSingleUse, isSoKeepAlive, isSoTcpNoDelay, onInit, processNioSelections, registerListener, registerSender, setActive, setApplicationEventPublisher, setDeserializer, setHost, setInterceptorFactoryChain, setLeaveOpen, setLookupHost, setMapper, setNioHarvestInterval, setPort, setReadDelay, setSerializer, setSingleUse, setSocketAttributes, setSoKeepAlive, setSoLinger, setSoReceiveBufferSize, setSoSendBufferSize, setSoTcpNoDelay, setSoTimeout, setSoTrafficClass, setSslHandshakeTimeout, setTaskExecutor, setTcpSocketSupport, stop, toString, unregisterSender, wrapConnectionafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskSchedulerpublic TcpNetClientConnectionFactory(String host, int port)
host - the hostport - the portprotected TcpConnectionSupport buildNewConnection()
buildNewConnection in class AbstractClientConnectionFactorypublic void setTcpNetConnectionSupport(TcpNetConnectionSupport connectionSupport)
TcpNetConnectionSupport to use to create connection objects.connectionSupport - the connection support.public void setTcpSocketFactorySupport(TcpSocketFactorySupport tcpSocketFactorySupport)
protected TcpSocketFactorySupport getTcpSocketFactorySupport()
public void start()
start in interface Lifecyclestart in interface ManageableLifecyclestart in class AbstractConnectionFactoryprotected Socket createSocket(String host, int port) throws IOException
Socket. This default implementation uses the default
SocketFactory. Override to use some other mechanismhost - The host.port - The port.IOException - Any IOException.