public class TcpNioClientConnectionFactory extends AbstractClientConnectionFactory implements Runnable
TcpNioConnections.DEFAULT_REPLY_TIMEOUT, lifecycleMonitorlogger| Constructor and Description |
|---|
TcpNioClientConnectionFactory(String host,
int port)
Creates a TcpNioClientConnectionFactory for connections to the host and port.
|
| Modifier and Type | Method and Description |
|---|---|
protected TcpConnectionSupport |
buildNewConnection() |
protected void |
checkActive() |
protected Map<SocketChannel,TcpNioConnection> |
getConnections() |
protected BlockingQueue<SocketChannel> |
getNewChannels() |
protected boolean |
isUsingDirectBuffers() |
void |
run() |
void |
setTcpNioConnectionSupport(TcpNioConnectionSupport tcpNioSupport) |
void |
setUsingDirectBuffers(boolean usingDirectBuffers)
When set to true, connections created by this factory attempt
to use direct buffers where possible.
|
void |
start() |
void |
stop()
Stops the server.
|
enableManualListenerRegistration, forceClose, getConnection, getTheConnection, initializeConnection, obtainConnection, obtainNewConnection, obtainSharedConnection, setTheConnectionaddConnection, closeConnection, delayRead, doAccept, getApplicationEventPublisher, getDelayedReads, getDeserializer, getHost, getListener, getMapper, getOpenConnectionIds, getPhase, getPort, getReadDelay, getSender, getSerializer, getSoLinger, getSoReceiveBufferSize, getSoSendBufferSize, getSoTimeout, getSoTrafficClass, getTaskExecutor, getTcpSocketSupport, harvestClosedConnections, isActive, isAutoStartup, isLookupHost, isRunning, isSingleUse, isSoKeepAlive, isSoTcpNoDelay, onInit, processNioSelections, registerListener, registerSender, setActive, setApplicationEventPublisher, setDeserializer, setInterceptorFactoryChain, setLookupHost, setMapper, setNioHarvestInterval, setReadDelay, setSerializer, setSingleUse, setSocketAttributes, setSoKeepAlive, setSoLinger, setSoReceiveBufferSize, setSoSendBufferSize, setSoTcpNoDelay, setSoTimeout, setSoTrafficClass, setTaskExecutor, setTcpSocketSupport, stop, toString, wrapConnectionafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getComponentType, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskSchedulerpublic TcpNioClientConnectionFactory(String host, int port)
host - the hostport - the portprotected void checkActive()
throws IOException
checkActive in class AbstractConnectionFactoryIOExceptionprotected TcpConnectionSupport buildNewConnection() throws Exception
buildNewConnection in class AbstractClientConnectionFactoryExceptionpublic void setUsingDirectBuffers(boolean usingDirectBuffers)
usingDirectBuffers - The usingDirectBuffers to set.ByteBufferpublic void setTcpNioConnectionSupport(TcpNioConnectionSupport tcpNioSupport)
public void stop()
AbstractConnectionFactorystop in interface Lifecyclestop in class AbstractConnectionFactorypublic void start()
start in interface Lifecyclestart in class AbstractConnectionFactoryprotected boolean isUsingDirectBuffers()
protected Map<SocketChannel,TcpNioConnection> getConnections()
protected BlockingQueue<SocketChannel> getNewChannels()