Package org.springframework.integration.ip.tcp.connection

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:

Runnable, Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, ApplicationEventPublisherAware, Lifecycle, ExpressionCapable, ConnectionFactory, NamedComponent, ManageableLifecycle, SchedulingAwareRunnable

public class TcpNioClientConnectionFactory
extends AbstractClientConnectionFactory
implements SchedulingAwareRunnable

A client connection factory that creates TcpNioConnections.

Since:

2.0

Author:

Gary Russell, Artem Bilan, Christian Tzolov

Field Summary

Fields inherited from class org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory

connections, connectionsMonitor, DEFAULT_REPLY_TIMEOUT, lifecycleMonitor

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Constructor Summary

Constructors

Constructor	Description
TcpNioClientConnectionFactory(String host, int port)	Creates a TcpNioClientConnectionFactory for connections to the host and port.

Method Summary

Modifier and Type	Method	Description
protected TcpConnectionSupport	buildNewConnection()
protected void	checkActive()
protected Map<SocketChannel,TcpNioConnection>	getConnections()
protected BlockingQueue<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.

Methods inherited from class org.springframework.integration.ip.tcp.connection.AbstractClientConnectionFactory

enableManualListenerRegistration, forceClose, getConnection, getConnectionTest, getConnectTimeout, getTheConnection, initializeConnection, obtainConnection, obtainNewConnection, obtainSharedConnection, setConnectionTest, setConnectTimeout, setTheConnection

Methods 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, wrapConnection

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.scheduling.SchedulingAwareRunnable

getQualifier

Constructor Details

TcpNioClientConnectionFactory

public TcpNioClientConnectionFactory(String host,
 int port)

Creates a TcpNioClientConnectionFactory for connections to the host and port.

Parameters:

host - the host

port - the port

Method Details

checkActive

protected void checkActive()

Overrides:

checkActive in class AbstractConnectionFactory

buildNewConnection

protected TcpConnectionSupport buildNewConnection()

Overrides:

buildNewConnection in class AbstractClientConnectionFactory

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

public void setTcpNioConnectionSupport(TcpNioConnectionSupport tcpNioSupport)

isLongLived

public boolean isLongLived()

Specified by:

isLongLived in interface SchedulingAwareRunnable

stop

public void stop()

Description copied from class: AbstractConnectionFactory

Stops the server.

Specified by:

stop in interface Lifecycle

Specified by:

stop in interface ManageableLifecycle

Overrides:

stop in class AbstractConnectionFactory

start

public void start()

Specified by:

start in interface Lifecycle

Specified by:

start in interface ManageableLifecycle

Overrides:

start in class AbstractConnectionFactory

run

public void run()

Specified by:

run in interface Runnable

isUsingDirectBuffers

protected boolean isUsingDirectBuffers()

Returns:

the usingDirectBuffers

getConnections

protected Map<SocketChannel,TcpNioConnection> getConnections()

Returns:

the connections

getNewChannels

protected BlockingQueue<SocketChannel> getNewChannels()

Returns:

the newChannels