Package | Description |
---|---|
org.springframework.integration.ip.tcp |
Base package for TCP Support.
|
org.springframework.integration.ip.tcp.connection |
All things related to tcp connections - client and
server factories; listener and sender interfaces.
|
Modifier and Type | Method and Description |
---|---|
protected TcpConnection |
TcpSendingMessageHandler.obtainConnection(Message<?> message) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,TcpConnection> |
TcpSendingMessageHandler.getConnections() |
Modifier and Type | Method and Description |
---|---|
void |
TcpOutboundGateway.addNewConnection(TcpConnection connection) |
void |
TcpSendingMessageHandler.addNewConnection(TcpConnection connection) |
void |
TcpInboundGateway.addNewConnection(TcpConnection connection) |
void |
TcpOutboundGateway.removeDeadConnection(TcpConnection connection) |
void |
TcpSendingMessageHandler.removeDeadConnection(TcpConnection connection) |
void |
TcpInboundGateway.removeDeadConnection(TcpConnection connection) |
Modifier and Type | Interface and Description |
---|---|
interface |
TcpConnectionInterceptor |
Modifier and Type | Class and Description |
---|---|
class |
TcpConnectionInterceptorSupport
Base class for TcpConnectionIntercepters; passes all method calls through
to the underlying
TcpConnection . |
class |
TcpConnectionSupport
Base class for TcpConnections.
|
class |
TcpNetConnection
A TcpConnection that uses and underlying
Socket . |
class |
TcpNioConnection
A TcpConnection that uses and underlying
SocketChannel . |
class |
TcpNioSSLConnection
Implementation of
TcpConnection supporting SSL/TLS over NIO. |
Modifier and Type | Method and Description |
---|---|
TcpConnection |
AbstractServerConnectionFactory.getConnection()
Not supported because the factory manages multiple connections and this
method cannot discriminate.
|
TcpConnection |
ConnectionFactory.getConnection() |
Modifier and Type | Method and Description |
---|---|
protected void |
TcpMessageMapper.addCustomHeaders(TcpConnection connection,
MessageBuilder<?> messageBuilder) |
void |
TcpSender.addNewConnection(TcpConnection connection)
When we are using sockets owned by a
TcpListener , this
method is called each time a new connection is made. |
void |
TcpConnectionInterceptorSupport.addNewConnection(TcpConnection connection) |
protected void |
TcpMessageMapper.addStandardHeaders(TcpConnection connection,
MessageBuilder<?> messageBuilder) |
void |
CachingClientConnectionFactory.forceClose(TcpConnection connection) |
void |
AbstractClientConnectionFactory.forceClose(TcpConnection connection)
Force close the connection and null the field if it's
a shared connection.
|
void |
TcpSender.removeDeadConnection(TcpConnection connection)
When we are using sockets owned by a
TcpListener , this
method is called each time a connection is closed. |
void |
TcpConnectionInterceptorSupport.removeDeadConnection(TcpConnection connection) |
protected Map<String,?> |
TcpMessageMapper.supplyCustomHeaders(TcpConnection connection)
Override to provide additional headers.
|
Message<Object> |
MessageConvertingTcpMessageMapper.toMessage(TcpConnection connection) |
Message<Object> |
TcpMessageMapper.toMessage(TcpConnection connection) |
Constructor and Description |
---|
TcpConnectionCloseEvent(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) |
Copyright © 2016. All rights reserved.