See: Description
Interface | Description |
---|---|
InterceptorChain |
The interceptor chain manages the flow of a message through a chain of interceptors and ultimately to the message
handler.
|
Message<T> |
Representation of a Message, containing a Payload and MetaData.
|
MessageDispatchInterceptor<T extends Message<?>> |
Interceptor that allows messages to be intercepted and modified before they are dispatched.
|
MessageHandler<T extends Message<?>> |
Interface for a component that processes Messages.
|
MessageHandlerInterceptor<T extends Message<?>> |
Workflow interface that allows for customized message handler invocation chains.
|
MessageStream<M extends Message<?>> |
Interface for a tracked stream of
Messages . |
StreamableMessageSource<M extends Message<?>> |
Interface for a source of
messages that processors can track. |
SubscribableMessageSource<M extends Message<?>> |
Interface for a source of
messages to which message processors can subscribe. |
Class | Description |
---|---|
AbstractMessage<T> |
Abstract base class for Messages.
|
DefaultInterceptorChain<T extends Message<?>> |
Mechanism that takes care of interceptor and handler execution.
|
GenericMessage<T> |
Generic implementation of a
Message that contains the payload and metadata as unserialized values. |
MessageDecorator<T> |
Abstract implementation of a
Message that delegates to an existing message. |
MetaData |
Represents MetaData that is passed along with a payload in a Message.
|
StreamUtils |
Utility class for working with Streams.
|
Exception | Description |
---|---|
ExecutionException |
Exception thrown to indicate that execution of a task has failed.
|
Copyright © 2010–2017. All rights reserved.