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
Implementation of TcpSocketFactorySupport for SSL sockets SSLServerSocket and SSLSocket.
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.