All Classes
| Class | Description |
|---|---|
| AbstractByteArraySerializer |
Base class for (de)serializers that provide a mechanism to
reconstruct a byte array from an arbitrary stream.
|
| AbstractClientConnectionFactory |
Abstract class for client connection factories; client connection factories
establish outgoing connections.
|
| AbstractConnectionFactory |
Base class for all connection factories.
|
| AbstractConnectionFactorySpec<S extends AbstractConnectionFactorySpec<S,C>,C extends AbstractConnectionFactory> |
An
IntegrationComponentSpec for AbstractConnectionFactorys. |
| AbstractInternetProtocolReceivingChannelAdapter |
Base class for inbound TCP/UDP Channel Adapters.
|
| AbstractInternetProtocolSendingMessageHandler |
Base class for UDP MessageHandlers.
|
| AbstractPooledBufferByteArraySerializer |
Base class for deserializers that cannot determine the buffer size needed.
|
| AbstractServerConnectionFactory |
Base class for all server connection factories.
|
| AbstractTcpConnectionSupport |
Base class for TCP Connection Support implementations.
|
| AbstractUdpOutboundChannelAdapterSpec<S extends AbstractUdpOutboundChannelAdapterSpec<S>> |
A
MessageHandlerSpec for UDP MessageHandlers. |
| ByteArrayCrLfSerializer |
Reads data in an InputStream to a byte[]; data must be terminated by \r\n
(not included in resulting byte[]).
|
| ByteArrayElasticRawDeserializer |
A deserializer that uses a
ByteArrayOutputStream instead of a fixed buffer,
allowing the buffer to grow as needed. |
| ByteArrayLengthHeaderSerializer |
Reads data in an InputStream to a byte[]; data must be preceded by
a binary length (network byte order, not included in resulting byte[]).
|
| ByteArrayLfSerializer | |
| ByteArrayRawSerializer |
A byte array (de)serializer that does nothing with the payload; sends it raw.
|
| ByteArraySingleTerminatorSerializer |
Reads data in an InputStream to a byte[]; data must be terminated by a single
byte (not included in resulting byte[]).
|
| ByteArrayStxEtxSerializer |
Reads data in an InputStream to a byte[]; data must be prefixed by <stx> and
terminated by <etx> (not included in resulting byte[]).
|
| CachingClientConnectionFactory |
Connection factory that caches connections from the underlying target factory.
|
| ClientModeCapable |
Edpoints implementing this interface are capable
of running in client-mode.
|
| ClientModeConnectionManager |
Intended to be run on a schedule, simply gets the connection
from a client connection factory each time it is run.
|
| CommonSocketOptions | |
| ConnectionFactory |
A factory used to create TcpConnection objects.
|
| DatagramPacketMessageMapper |
Message Mapper for converting to and from UDP DatagramPackets.
|
| DefaultTcpNetConnectionSupport |
Default implementation of
TcpNetConnectionSupport. |
| DefaultTcpNetSocketFactorySupport |
Implementation of TcpSocketFactorySupport
for non-SSL sockets
ServerSocket and
Socket. |
| DefaultTcpNetSSLSocketFactorySupport | |
| DefaultTcpNioConnectionSupport |
Implementation of
TcpNioConnectionSupport for non-SSL
NIO connections. |
| DefaultTcpNioSSLConnectionSupport |
Implementation of
TcpNioConnectionSupport for SSL
NIO connections. |
| DefaultTcpSocketSupport |
Default implementation of
TcpSocketSupport; makes no
changes to sockets. |
| DefaultTcpSSLContextSupport |
Default implementation of
TcpSSLContextSupport; uses a
'TLS' (by default) SSLContext, initialized with 'JKS'
keystores, managed by 'SunX509' Key and Trust managers. |
| FailoverClientConnectionFactory |
Given a list of connection factories, serves up
TcpConnections
that can iterate over a connection from each factory until the write
succeeds or the list is exhausted. |
| IpAdapterParserUtils |
Utility methods and constants for IP adapter parsers.
|
| IpHeaders |
Headers for Messages mapped from IP datagram packets.
|
| IpIntegrationEvent | |
| IpNamespaceHandler |
Namespace handler for Spring Integration's ip namespace.
|
| MapJsonSerializer |
Serializes a
Map as JSON. |
| MessageConvertingTcpMessageMapper | |
| MulticastReceivingChannelAdapter |
Channel adapter that joins a multicast group and receives incoming packets and
sends them to an output channel.
|
| MulticastSendingMessageHandler |
A
MessageHandler implementation that maps a
Message into a UDP datagram packet and sends that to the specified multicast address
(224.0.0.0 to 239.255.255.255) and port. |
| NoListenerException | |
| RegexUtils |
Regular Expression Utilities.
|
| SocketCustomizer |
Configures a socket.
|
| SocketInfo |
Simple wrapper around
Socket providing access to getters (except
input/output streams). |
| SoftEndOfStreamException |
Used to communicate that a stream has closed, but between logical
messages.
|
| Tcp |
Factory methods for TCP.
|
| TcpClientConnectionFactorySpec | |
| TcpCodecs |
Factory class to create TCP Serializer/Deserializers used to
encode/decode messages to/from a TCP stream.
|
| TcpConnection |
An abstraction over
Socket and SocketChannel
that sends Message objects by serializing the payload and streaming it to the
destination. |
| TcpConnectionCloseEvent | |
| TcpConnectionEvent |
ApplicationEvent representing normal operations on a
TcpConnection. |
| TcpConnectionExceptionEvent |
ApplicationEvent representing exceptions on a
TcpConnection. |
| TcpConnectionFactoryFactoryBean |
Instantiates a TcpN(et|io)(Server|Client)ConnectionFactory, depending
on type and using-nio attributes.
|
| TcpConnectionFactoryParser | |
| TcpConnectionFailedCorrelationEvent |
An event emitted when an endpoint cannot correlate a connection id to a
connection; the cause is a messaging exception with the failed message.
|
| TcpConnectionFailedEvent |
An event emitted when a connection could not be established for some
reason.
|
| TcpConnectionInterceptor | |
| TcpConnectionInterceptorFactory |
Interface for TCP connection interceptor factories.
|
| TcpConnectionInterceptorFactoryChain | |
| TcpConnectionInterceptorSupport |
Base class for
TcpConnectionInterceptors; passes all method calls through
to the underlying TcpConnection. |
| TcpConnectionOpenEvent | |
| TcpConnectionServerExceptionEvent |
IpIntegrationEvent representing exceptions on a TCP server socket/channel. |
| TcpConnectionServerListeningEvent |
IpIntegrationEvent emitted when a server begins listening. |
| TcpConnectionSupport |
Base class for TcpConnections.
|
| TcpDeserializationExceptionEvent |
Event representing an exception while decoding an incoming stream.
|
| TcpInboundChannelAdapterParser |
Channel Adapter that receives TCP stream frames and maps them to Messages.
|
| TcpInboundChannelAdapterSpec |
A
MessageProducerSpec for TcpReceivingChannelAdapters. |
| TcpInboundGateway |
Inbound Gateway using a server connection factory - threading is controlled by the
factory.
|
| TcpInboundGatewayParser | |
| TcpInboundGatewaySpec |
A
MessagingGatewaySpec for TcpInboundGateways. |
| TcpListener |
Classes that implement this interface may register with a
connection factory to receive messages retrieved from a
TcpConnection |
| TcpMessageMapper |
Maps incoming data from a
TcpConnection to a Message. |
| TcpNetClientConnectionFactory |
A client connection factory that creates
TcpNetConnections. |
| TcpNetConnection |
A TcpConnection that uses and underlying
Socket. |
| TcpNetConnectionSupport |
Used by NET connection factories to instantiate a
TcpNetConnection object. |
| TcpNetServerConnectionFactory |
Implements a server connection factory that produces
TcpNetConnections using
a ServerSocket. |
| TcpNioClientConnectionFactory |
A client connection factory that creates
TcpNioConnections. |
| TcpNioConnection |
A TcpConnection that uses and underlying
SocketChannel. |
| TcpNioConnectionSupport |
Used by NIO connection factories to instantiate a
TcpNioConnection object. |
| TcpNioServerConnectionFactory |
/**
Implements a server connection factory that produces
TcpNioConnections using
a ServerSocketChannel. |
| TcpNioSSLConnection |
Implementation of
TcpConnection supporting SSL/TLS over NIO. |
| TcpOutboundChannelAdapterParser | |
| TcpOutboundChannelAdapterSpec |
A
MessageHandlerSpec for TcpSendingMessageHandlers. |
| TcpOutboundGateway |
TCP outbound gateway that uses a client connection factory.
|
| TcpOutboundGatewayParser |
Parser for the <outbound-gateway> element of the integration 'jms' namespace.
|
| TcpOutboundGatewaySpec |
A
MessageHandlerSpec for TcpOutboundGateways. |
| TcpReceivingChannelAdapter |
Tcp inbound channel adapter using a TcpConnection to
receive data - if the connection factory is a server
factory, this Listener owns the connections.
|
| TcpSender |
An interface representing a sending client of a connection
factory.
|
| TcpSendingMessageHandler |
Tcp outbound channel adapter using a TcpConnection to
send data - if the connection factory is a server
factory, the TcpListener owns the connections.
|
| TcpServerConnectionFactory |
Connection factories that act as TCP servers, listening for incoming connections.
|
| TcpServerConnectionFactorySpec | |
| TcpSocketFactorySupport |
Strategy interface for supplying Socket Factories.
|
| TcpSocketSupport |
Strategy interface for modifying sockets.
|
| TcpSSLContextSupport |
Strategy interface for the creation of an
SSLContext object
for use with SSL/TLS sockets. |
| TestingUtilities |
Convenience class providing methods for testing IP components.
|
| ThreadAffinityClientConnectionFactory |
A client connection factory that binds a connection to a thread.
|
| Udp |
Factory methods for UDP.
|
| UdpInboundChannelAdapterParser |
Channel Adapter that receives UDP datagram packets and maps them to Messages.
|
| UdpInboundChannelAdapterSpec |
A
MessageProducerSpec for UnicastReceivingChannelAdapters. |
| UdpMulticastOutboundChannelAdapterSpec |
A
MessageHandlerSpec for
MulticastSendingMessageHandlers. |
| UdpOutboundChannelAdapterParser | |
| UdpServerListeningEvent |
IpIntegrationEvent emitted when a server begins listening. |
| UdpUnicastOutboundChannelAdapterSpec |
A
MessageHandlerSpec for
UnicastSendingMessageHandlers. |
| UnicastReceivingChannelAdapter |
A channel adapter to receive incoming UDP packets.
|
| UnicastSendingMessageHandler |
A
MessageHandler implementation that maps a Message into
a UDP datagram packet and sends that to the specified host and port. |