| 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.