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

java.lang.Object
  extended by org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory
      extended by org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory
          extended by org.springframework.integration.ip.tcp.connection.TcpNetServerConnectionFactory
All Implemented Interfaces:
java.lang.Runnable, Lifecycle, Phased, SmartLifecycle, ConnectionFactory

public class TcpNetServerConnectionFactory
extends AbstractServerConnectionFactory

Implements a server connection factory that produces TcpNetConnections using a ServerSocket. Must have a TcpListener registered.

Since:
2.0

Field Summary
protected  java.net.ServerSocket serverSocket
           
 
Fields inherited from class org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory
listening, localAddress
 
Fields inherited from class org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory
active, DEFAULT_REPLY_TIMEOUT, deserializer, host, interceptorFactoryChain, lifecycleMonitor, listener, logger, mapper, poolSize, port, sender, serializer, singleUse, soTimeout
 
Constructor Summary
TcpNetServerConnectionFactory(int port)
          Listens for incoming connections on the port.
 
Method Summary
 void close()
          Closes the server.
 boolean isRunning()
           
 void run()
          If no listener registers, exits.
 
Methods inherited from class org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory
getConnection, getLocalAddress, initializeConnection, isListening, setLocalAddress
 
Methods inherited from class org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory
addConnection, doAccept, getHost, getPhase, getPort, getSoLinger, getSoReceiveBufferSize, getSoSendBufferSize, getSoTimeout, getSoTrafficClass, getTaskExecutor, harvestClosedConnections, isAutoStartup, isLookupHost, isSingleUse, isSoKeepAlive, isSoTcpNoDelay, processNioSelections, registerListener, registerSender, setDeserializer, setInterceptorFactoryChain, setLookupHost, setMapper, setPoolSize, setSerializer, setSingleUse, setSocketAttributes, setSoKeepAlive, setSoLinger, setSoReceiveBufferSize, setSoSendBufferSize, setSoTcpNoDelay, setSoTimeout, setSoTrafficClass, setTaskExecutor, start, stop, stop, wrapConnection
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

serverSocket

protected java.net.ServerSocket serverSocket
Constructor Detail

TcpNetServerConnectionFactory

public TcpNetServerConnectionFactory(int port)
Listens for incoming connections on the port.

Parameters:
port - The port.
Method Detail

run

public void run()
If no listener registers, exits. Accepts incoming connections and creates TcpConnections for each new connection. Invokes {AbstractServerConnectionFactory.initializeConnection(TcpConnection, Socket) and executes the connection Runnable.run() using the task executor. I/O errors on the server socket/channel are logged and the factory is stopped.


isRunning

public boolean isRunning()

close

public void close()
Description copied from class: AbstractConnectionFactory
Closes the server.

Specified by:
close in class AbstractConnectionFactory