public class TcpNioClientConnectionFactory extends AbstractClientConnectionFactory implements Runnable
TcpNioConnection
s.DEFAULT_REPLY_TIMEOUT, lifecycleMonitor
logger
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.
|
forceClose, getConnection, getTheConnection, initializeConnection, obtainConnection, obtainNewConnection, obtainSharedConnection, setTheConnection
addConnection, closeConnection, doAccept, getApplicationEventPublisher, getDeserializer, getHost, getListener, getMapper, getOpenConnectionIds, getPhase, getPort, 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, setSerializer, setSingleUse, setSocketAttributes, setSoKeepAlive, setSoLinger, setSoReceiveBufferSize, setSoSendBufferSize, setSoTcpNoDelay, setSoTimeout, setSoTrafficClass, setTaskExecutor, setTcpSocketSupport, stop, wrapConnection
afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getComponentType, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
public TcpNioClientConnectionFactory(String host, int port)
host
- the hostport
- the portprotected void checkActive() throws IOException
checkActive
in class AbstractConnectionFactory
IOException
protected TcpConnectionSupport buildNewConnection() throws Exception
buildNewConnection
in class AbstractClientConnectionFactory
Exception
public void setUsingDirectBuffers(boolean usingDirectBuffers)
usingDirectBuffers
- The usingDirectBuffers to set.ByteBuffer
public void setTcpNioConnectionSupport(TcpNioConnectionSupport tcpNioSupport)
public void stop()
AbstractConnectionFactory
stop
in interface Lifecycle
stop
in class AbstractConnectionFactory
public void start()
start
in interface Lifecycle
start
in class AbstractConnectionFactory
protected boolean isUsingDirectBuffers()
protected Map<SocketChannel,TcpNioConnection> getConnections()
protected BlockingQueue<SocketChannel> getNewChannels()