public class TcpNetServerConnectionFactory extends AbstractServerConnectionFactory
TcpNetConnections using
a ServerSocket. Must have a TcpListener registered.DEFAULT_REPLY_TIMEOUT, lifecycleMonitorEXPRESSION_PARSER, logger| Constructor and Description |
|---|
TcpNetServerConnectionFactory(int port)
Listens for incoming connections on the port.
|
| Modifier and Type | Method and Description |
|---|---|
protected ServerSocket |
createServerSocket(int port,
int backlog,
InetAddress whichNic)
Create a new
ServerSocket. |
String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
int |
getPort()
Return the port this server is listening on.
|
protected ServerSocket |
getServerSocket() |
SocketAddress |
getServerSocketAddress()
Return the
SocketAddress that the underlying ServerSocket
is bound to. |
protected TcpSocketFactorySupport |
getTcpSocketFactorySupport() |
void |
run()
If no listener registers, exits.
|
void |
setTcpNetConnectionSupport(TcpNetConnectionSupport connectionSupport)
Set the
TcpNetConnectionSupport to use to create connection objects. |
void |
setTcpSocketFactorySupport(TcpSocketFactorySupport tcpSocketFactorySupport) |
void |
stop()
Stops the server.
|
afterShutdown, beforeShutdown, getBacklog, getConnection, getLocalAddress, initializeConnection, isListening, isLongLived, isShuttingDown, postProcessServerSocket, publishServerExceptionEvent, publishServerListeningEvent, setBacklog, setListening, setLocalAddress, startaddConnection, checkActive, closeConnection, delayRead, doAccept, getApplicationEventPublisher, getDelayedReads, getDeserializer, getHost, getListener, getMapper, getOpenConnectionIds, getReadDelay, getSender, 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, wrapConnectionafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskSchedulerpublic TcpNetServerConnectionFactory(int port)
port - The port.public String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class IntegrationObjectSupportpublic int getPort()
TcpServerConnectionFactorygetPort in interface TcpServerConnectionFactorygetPort in class AbstractConnectionFactory@Nullable public SocketAddress getServerSocketAddress()
TcpServerConnectionFactorySocketAddress that the underlying ServerSocket
is bound to.getServerSocketAddress in interface TcpServerConnectionFactorygetServerSocketAddress in class AbstractServerConnectionFactorypublic void setTcpNetConnectionSupport(TcpNetConnectionSupport connectionSupport)
TcpNetConnectionSupport to use to create connection objects.connectionSupport - the connection support.public void run()
AbstractServerConnectionFactory.initializeConnection(TcpConnectionSupport, 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.protected ServerSocket createServerSocket(int port, int backlog, @Nullable InetAddress whichNic) throws IOException
ServerSocket. This default implementation uses the default
ServerSocketFactory. Override to use some other mechanismport - The port.backlog - The server socket backlog.whichNic - An InetAddress if binding to a specific network interface. Set to
null when configured to bind to all interfaces.IOException - Any IOException.public void stop()
AbstractConnectionFactorystop in interface Lifecyclestop in class AbstractConnectionFactoryprotected ServerSocket getServerSocket()
protected TcpSocketFactorySupport getTcpSocketFactorySupport()
public void setTcpSocketFactorySupport(TcpSocketFactorySupport tcpSocketFactorySupport)