Message
along with
a MessageBuilder and MessageHeaderAccessor for building and working with messages and
message headers, as well as various MessageChannel
implementations and channel interceptor support.See: Description
Interface | Description |
---|---|
ChannelInterceptor |
Interface for interceptors that are able to view and/or modify the
Messages being sent-to and/or received-from a
MessageChannel . |
ExecutorChannelInterceptor |
An extension of
ChannelInterceptor with callbacks to intercept the
asynchronous sending of a Message to
a specific subscriber through an Executor . |
HeaderMapper<T> |
Generic strategy interface for mapping
MessageHeaders to and from other
types of objects. |
InterceptableChannel |
A
MessageChannel that
maintains a list ChannelInterceptors and allows interception of message sending. |
MessageHandlingRunnable |
Extension of the
Runnable interface with methods to obtain the
MessageHandler and Message to be handled. |
MessageHeaderInitializer |
Callback interface for initializing a
MessageHeaderAccessor . |
Class | Description |
---|---|
AbstractHeaderMapper<T> |
A base
HeaderMapper implementation. |
AbstractMessageChannel |
Abstract base class for
MessageChannel implementations. |
AbstractSubscribableChannel |
Abstract base class for
SubscribableChannel implementations. |
ChannelInterceptorAdapter | Deprecated
as of 5.0.7
ChannelInterceptor has default methods (made
possible by a Java 8 baseline) and can be implemented directly without the
need for this no-op adapter |
ErrorMessage |
A
GenericMessage with a Throwable payload. |
ExecutorSubscribableChannel |
A
SubscribableChannel that sends messages to each of its subscribers. |
GenericMessage<T> |
An implementation of
Message with a generic payload. |
IdTimestampMessageHeaderInitializer |
A
MessageHeaderInitializer
to customize the strategy for ID and TIMESTAMP message header generation. |
ImmutableMessageChannelInterceptor |
A simpler interceptor that calls
MessageHeaderAccessor.setImmutable()
on the headers of messages passed through the preSend method. |
MessageBuilder<T> | |
MessageHeaderAccessor |
A base for classes providing strongly typed getters and setters as well as
behavior around specific categories of headers (e.g.
|
MonoToListenableFutureAdapter<T> |
A Mono-to-ListenableFuture adapter where the source and the target from
the Promise and the ListenableFuture respectively are of the same type.
|
NativeMessageHeaderAccessor |
An extension of
MessageHeaderAccessor that also stores and provides read/write
access to message headers from an external source -- e.g. |
Message
along with
a MessageBuilder and MessageHeaderAccessor for building and working with messages and
message headers, as well as various MessageChannel
implementations and channel interceptor support.