org.springframework.integration.ip.tcp.connection
Class AbstractServerConnectionFactory

java.lang.Object
  org.springframework.integration.context.IntegrationObjectSupport
      org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory
          org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory

All Implemented Interfaces:

java.lang.Runnable, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, NamedComponent, ConnectionFactory

Direct Known Subclasses:

TcpNetServerConnectionFactory, TcpNioServerConnectionFactory

public abstract class AbstractServerConnectionFactory
extends AbstractConnectionFactory

Base class for all server connection factories. Server connection factories listen on a port for incoming connections and create new TcpConnection objects for each new connection.

Since:

2.0

Author:

Gary Russell

Field Summary

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

DEFAULT_REPLY_TIMEOUT, lifecycleMonitor

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

logger

Constructor Summary

AbstractServerConnectionFactory(int port)
The port on which the factory will listen.

Method Summary

TcpConnection	getConnection() Not supported because the factory manages multiple connections and this method cannot discriminate.
java.lang.String	getLocalAddress()
protected void	initializeConnection(TcpConnection connection, java.net.Socket socket) Transfers attributes such as (de)serializer, singleUse etc to a new connection.
boolean	isListening()
protected void	setListening(boolean listening)
void	setLocalAddress(java.lang.String localAddress) Used on multi-homed systems to enforce the server to listen on a specfic network address instead of all network adapters.

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

addConnection, checkActive, close, doAccept, getDeserializer, getHost, getListener, getMapper, getPhase, getPoolSize, getPort, getSender, getSerializer, getSoLinger, getSoReceiveBufferSize, getSoSendBufferSize, getSoTimeout, getSoTrafficClass, getTaskExecutor, harvestClosedConnections, isActive, isAutoStartup, isLookupHost, isRunning, isSingleUse, isSoKeepAlive, isSoTcpNoDelay, processNioSelections, registerListener, registerSender, setActive, setDeserializer, setInterceptorFactoryChain, setLookupHost, setMapper, setPoolSize, setSerializer, setSingleUse, setSocketAttributes, setSoKeepAlive, setSoLinger, setSoReceiveBufferSize, setSoSendBufferSize, setSoTcpNoDelay, setSoTimeout, setSoTrafficClass, setTaskExecutor, start, stop, stop, wrapConnection

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

afterPropertiesSet, getBeanFactory, getComponentName, getComponentType, getConversionService, getTaskScheduler, onInit, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Constructor Detail

AbstractServerConnectionFactory

public AbstractServerConnectionFactory(int port)

The port on which the factory will listen.

Parameters:

port -

Method Detail

getConnection

public TcpConnection getConnection()
                            throws java.lang.Exception

Not supported because the factory manages multiple connections and this method cannot discriminate.

Throws:

java.lang.Exception

setListening

protected void setListening(boolean listening)

Parameters:

listening - the listening to set

isListening

public boolean isListening()

Returns:

true if the server is listening on the port.

initializeConnection

protected void initializeConnection(TcpConnection connection,
                                    java.net.Socket socket)

Transfers attributes such as (de)serializer, singleUse etc to a new connection. For single use sockets, enforces a socket timeout (default 10 seconds).

Parameters:

connection - The new connection.

socket - The new socket.

getLocalAddress

public java.lang.String getLocalAddress()

Returns:

the localAddress

setLocalAddress

public void setLocalAddress(java.lang.String localAddress)

Used on multi-homed systems to enforce the server to listen on a specfic network address instead of all network adapters.

Parameters:

localAddress - the ip address of the required adapter.