Uses of Interface
org.springframework.integration.ip.tcp.connection.TcpConnection
Package
Description
Base package for TCP Support.
All things related to tcp connections - client and
server factories; listener and sender interfaces.
-
Uses of TcpConnection in org.springframework.integration.ip.tcp
Modifier and TypeMethodDescriptionprotected TcpConnection
Method that actually does the write.protected TcpConnection
TcpSendingMessageHandler.obtainConnection
(Message<?> message) Modifier and TypeMethodDescriptionprotected Map<String,
TcpConnection> TcpSendingMessageHandler.getConnections()
Modifier and TypeMethodDescriptionvoid
TcpInboundGateway.addNewConnection
(TcpConnection connection) void
TcpOutboundGateway.addNewConnection
(TcpConnection connection) void
TcpSendingMessageHandler.addNewConnection
(TcpConnection connection) void
TcpInboundGateway.removeDeadConnection
(TcpConnection connection) void
TcpOutboundGateway.removeDeadConnection
(TcpConnection connection) void
TcpSendingMessageHandler.removeDeadConnection
(TcpConnection connection) -
Uses of TcpConnection in org.springframework.integration.ip.tcp.connection
Modifier and TypeClassDescriptionclass
Base class forTcpConnectionInterceptor
s; passes all method calls through to the underlyingTcpConnection
.class
Base class for TcpConnections.class
A TcpConnection that uses and underlyingSocket
.class
A TcpConnection that uses and underlyingSocketChannel
.class
Implementation ofTcpConnection
supporting SSL/TLS over NIO.Modifier and TypeMethodDescriptionAbstractServerConnectionFactory.getConnection()
Not supported because the factory manages multiple connections and this method cannot discriminate.ConnectionFactory.getConnection()
Modifier and TypeMethodDescriptionprotected final void
TcpMessageMapper.addCustomHeaders
(TcpConnection connection, MessageHeaders messageHeaders) void
TcpConnectionInterceptorSupport.addNewConnection
(TcpConnection connection) void
TcpSender.addNewConnection
(TcpConnection connection) When we are using sockets owned by aTcpListener
, this method is called each time a new connection is made.protected final void
TcpMessageMapper.addStandardHeaders
(TcpConnection connection, MessageHeaders messageHeaders) void
AbstractClientConnectionFactory.forceClose
(TcpConnection connection) Force close the connection and null the field if it's a shared connection.void
CachingClientConnectionFactory.forceClose
(TcpConnection connection) void
ThreadAffinityClientConnectionFactory.forceClose
(TcpConnection connection) void
TcpConnectionInterceptorSupport.removeDeadConnection
(TcpConnection connection) default void
TcpSender.removeDeadConnection
(TcpConnection connection) When we are using sockets owned by aTcpListener
, this method is called each time a connection is closed.TcpMessageMapper.supplyCustomHeaders
(TcpConnection connection) Override to provide additional headers.Message<?>
MessageConvertingTcpMessageMapper.toMessage
(TcpConnection connection, Map<String, Object> headers) Message<?>
TcpMessageMapper.toMessage
(TcpConnection connection, Map<String, Object> headers) ModifierConstructorDescriptionTcpConnectionCloseEvent
(TcpConnection connection, String connectionFactoryName) TcpConnectionEvent
(TcpConnection connection, String connectionFactoryName) TcpConnectionEvent
(TcpConnection connection, String connectionFactoryName, Throwable cause) TcpConnectionExceptionEvent
(TcpConnection connection, String connectionFactoryName, Throwable cause) TcpConnectionOpenEvent
(TcpConnection connection, String connectionFactoryName)