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

Class TcpNetClientConnectionFactory

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.TcpNetClientConnectionFactory

All Implemented Interfaces:

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

public class TcpNetClientConnectionFactory
extends AbstractClientConnectionFactory

A client connection factory that creates TcpNetConnections.

Since:

2.0

Author:

Gary Russell, Artem Bilan

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
TcpNetClientConnectionFactory(String host, int port)	Creates a TcpNetClientConnectionFactory for connections to the host and port.

Method Summary

Modifier and Type	Method	Description
protected TcpConnectionSupport	buildNewConnection()
protected Socket	createSocket(String host, int port)	Create a new Socket.
protected TcpSocketFactorySupport	getTcpSocketFactorySupport()
void	setTcpNetConnectionSupport(TcpNetConnectionSupport connectionSupport)	Set the TcpNetConnectionSupport to use to create connection objects.
void	setTcpSocketFactorySupport(TcpSocketFactorySupport tcpSocketFactorySupport)	Set the TcpSocketFactorySupport used to create server sockets.
void	start()

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, checkActive, 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, stop, 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

Constructor Details

TcpNetClientConnectionFactory

public TcpNetClientConnectionFactory(String host,
 int port)

Creates a TcpNetClientConnectionFactory for connections to the host and port.

Parameters:

host - the host

port - the port

Method Details

buildNewConnection

protected TcpConnectionSupport buildNewConnection()

Overrides:

buildNewConnection in class AbstractClientConnectionFactory

setTcpNetConnectionSupport

public void setTcpNetConnectionSupport(TcpNetConnectionSupport connectionSupport)

Set the TcpNetConnectionSupport to use to create connection objects.

Parameters:

connectionSupport - the connection support.

Since:

5.0

setTcpSocketFactorySupport

public void setTcpSocketFactorySupport(TcpSocketFactorySupport tcpSocketFactorySupport)

Set the TcpSocketFactorySupport used to create server sockets.

Parameters:

tcpSocketFactorySupport - the TcpSocketFactorySupport

getTcpSocketFactorySupport

protected TcpSocketFactorySupport getTcpSocketFactorySupport()

start

public void start()

Specified by:

start in interface Lifecycle

Specified by:

start in interface ManageableLifecycle

Overrides:

start in class AbstractConnectionFactory

createSocket

protected Socket createSocket(String host,
 int port)
                       throws IOException

Create a new Socket. This default implementation uses the default SocketFactory. Override to use some other mechanism

Parameters:

host - The host.

port - The port.

Returns:

The Socket

Throws:

IOException - Any IOException.