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.
|
| MessageDispatchInterceptorSupport<T extends Message<?>> |
Interface marking components capable of registering Dispatch Interceptors.
|
| 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.
|
| MessageHandlerInterceptorSupport<T extends Message<?>> |
Interface marking components capable of registering Handler Interceptors.
|
| MessageStream<M extends Message<?>> |
Interface for a tracked stream of
Messages. |
| ScopeAware |
Interface describing components which are
Scope aware. |
| ScopeAwareProvider |
Contract towards a mechanism to provide a
Stream of components which are ScopeAware. |
| ScopeDescriptor |
Denotes the description of a
Scope. |
| 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. |
| Headers |
Default headers to include when publishing a message on a broker.
|
| 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.
|
| Scope |
Describes functionality off processes which can be 'in scope', like the
AggregateLifecycle or
SagaLifecycle. |
| StreamUtils |
Utility class for working with Streams.
|
| Exception | Description |
|---|---|
| EventPublicationFailedException |
Exception indication that an error occurred while publishing an event to an AMQP Broker
|
| ExecutionException |
Exception thrown to indicate that execution of a task has failed.
|
Copyright © 2010–2018. All rights reserved.