Class TcpNioClientConnectionFactory
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory
org.springframework.integration.ip.tcp.connection.AbstractClientConnectionFactory
org.springframework.integration.ip.tcp.connection.TcpNioClientConnectionFactory
- All Implemented Interfaces:
java.lang.Runnable,org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.InitializingBean,org.springframework.context.ApplicationContextAware,org.springframework.context.ApplicationEventPublisherAware,org.springframework.context.Lifecycle,org.springframework.integration.context.ExpressionCapable,ConnectionFactory,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.ManageableLifecycle,org.springframework.scheduling.SchedulingAwareRunnable
public class TcpNioClientConnectionFactory extends AbstractClientConnectionFactory implements org.springframework.scheduling.SchedulingAwareRunnable
A client connection factory that creates
TcpNioConnections.- Since:
- 2.0
-
Field Summary
Fields inherited from class org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory
DEFAULT_REPLY_TIMEOUT, lifecycleMonitor -
Constructor Summary
Constructors Constructor Description TcpNioClientConnectionFactory(java.lang.String host, int port)Creates a TcpNioClientConnectionFactory for connections to the host and port. -
Method Summary
Modifier and Type Method Description protected TcpConnectionSupportbuildNewConnection()protected voidcheckActive()protected java.util.Map<java.nio.channels.SocketChannel,TcpNioConnection>getConnections()protected java.util.concurrent.BlockingQueue<java.nio.channels.SocketChannel>getNewChannels()booleanisLongLived()protected booleanisUsingDirectBuffers()voidrun()voidsetTcpNioConnectionSupport(TcpNioConnectionSupport tcpNioSupport)voidsetUsingDirectBuffers(boolean usingDirectBuffers)When set to true, connections created by this factory attempt to use direct buffers where possible.voidstart()voidstop()Stops the server.Methods inherited from class org.springframework.integration.ip.tcp.connection.AbstractClientConnectionFactory
enableManualListenerRegistration, forceClose, getConnection, getConnectionTest, getConnectTimeout, getTheConnection, initializeConnection, obtainConnection, obtainNewConnection, obtainSharedConnection, setConnectionTest, setConnectTimeout, setTheConnectionMethods inherited from class org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory
addConnection, 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, toString, unregisterSender, wrapConnectionMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, 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, setTaskScheduler
-
Constructor Details
-
TcpNioClientConnectionFactory
public TcpNioClientConnectionFactory(java.lang.String host, int port)Creates a TcpNioClientConnectionFactory for connections to the host and port.- Parameters:
host- the hostport- the port
-
-
Method Details
-
checkActive
protected void checkActive()- Overrides:
checkActivein classAbstractConnectionFactory
-
buildNewConnection
- Overrides:
buildNewConnectionin classAbstractClientConnectionFactory
-
setUsingDirectBuffers
public void setUsingDirectBuffers(boolean usingDirectBuffers)When set to true, connections created by this factory attempt to use direct buffers where possible.- Parameters:
usingDirectBuffers- The usingDirectBuffers to set.- See Also:
ByteBuffer
-
setTcpNioConnectionSupport
-
isLongLived
public boolean isLongLived()- Specified by:
isLongLivedin interfaceorg.springframework.scheduling.SchedulingAwareRunnable
-
stop
public void stop()Description copied from class:AbstractConnectionFactoryStops the server.- Specified by:
stopin interfaceorg.springframework.context.Lifecycle- Specified by:
stopin interfaceorg.springframework.integration.support.management.ManageableLifecycle- Overrides:
stopin classAbstractConnectionFactory
-
start
public void start()- Specified by:
startin interfaceorg.springframework.context.Lifecycle- Specified by:
startin interfaceorg.springframework.integration.support.management.ManageableLifecycle- Overrides:
startin classAbstractConnectionFactory
-
run
public void run()- Specified by:
runin interfacejava.lang.Runnable
-
isUsingDirectBuffers
protected boolean isUsingDirectBuffers()- Returns:
- the usingDirectBuffers
-
getConnections
- Returns:
- the connections
-
getNewChannels
protected java.util.concurrent.BlockingQueue<java.nio.channels.SocketChannel> getNewChannels()- Returns:
- the newChannels
-