public class TcpNioClientConnectionFactory extends AbstractClientConnectionFactory implements org.springframework.scheduling.SchedulingAwareRunnable
TcpNioConnection
s.DEFAULT_REPLY_TIMEOUT, lifecycleMonitor
EXPRESSION_PARSER, logger
Constructor and Description |
---|
TcpNioClientConnectionFactory(java.lang.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 java.util.Map<java.nio.channels.SocketChannel,TcpNioConnection> |
getConnections() |
protected java.util.concurrent.BlockingQueue<java.nio.channels.SocketChannel> |
getNewChannels() |
boolean |
isLongLived() |
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, setTheConnection
addConnection, closeConnection, delayRead, doAccept, getApplicationEventPublisher, getDelayedReads, getDeserializer, getHost, getListener, getMapper, getOpenConnectionIds, getPort, getReadDelay, getSender, 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, toString, wrapConnection
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler
public TcpNioClientConnectionFactory(java.lang.String host, int port)
host
- the hostport
- the portprotected void checkActive() throws java.io.IOException
checkActive
in class AbstractConnectionFactory
java.io.IOException
protected TcpConnectionSupport buildNewConnection() throws java.lang.Exception
buildNewConnection
in class AbstractClientConnectionFactory
java.lang.Exception
public void setUsingDirectBuffers(boolean usingDirectBuffers)
usingDirectBuffers
- The usingDirectBuffers to set.ByteBuffer
public void setTcpNioConnectionSupport(TcpNioConnectionSupport tcpNioSupport)
public boolean isLongLived()
isLongLived
in interface org.springframework.scheduling.SchedulingAwareRunnable
public void stop()
AbstractConnectionFactory
stop
in interface org.springframework.context.Lifecycle
stop
in class AbstractConnectionFactory
public void start()
start
in interface org.springframework.context.Lifecycle
start
in class AbstractConnectionFactory
public void run()
run
in interface java.lang.Runnable
protected boolean isUsingDirectBuffers()
protected java.util.Map<java.nio.channels.SocketChannel,TcpNioConnection> getConnections()
protected java.util.concurrent.BlockingQueue<java.nio.channels.SocketChannel> getNewChannels()