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.