See: Description
| Interface | Description |
|---|---|
| CorrelationStrategy |
Strategy for determining how messages can be correlated.
|
| MessageGroupProcessor |
A processor for correlated groups of messages.
|
| MessageListProcessor | |
| ReleaseStrategy |
Strategy for determining when a group of messages reaches a state of
completion (i.e.
|
| Class | Description |
|---|---|
| AbstractAggregatingMessageGroupProcessor |
Base class for MessageGroupProcessor implementations that aggregate the group of Messages into a single Message.
|
| AbstractCorrelatingMessageHandler |
Abstract Message handler that holds a buffer of correlated messages in a
MessageStore. |
| AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup | |
| AggregatingMessageHandler |
Aggregator specific implementation of
AbstractCorrelatingMessageHandler. |
| BarrierMessageHandler |
A message handler that suspends the thread until a message with corresponding
correlation is passed into the
trigger method or
the timeout occurs. |
| CorrelatingMessageBarrier |
This Endpoint serves as a barrier for messages that should not be processed yet.
|
| DefaultAggregateHeadersFunction |
The
Function implementation for a default headers merging in the aggregator
component. |
| DefaultAggregatingMessageGroupProcessor |
This implementation of MessageGroupProcessor will take the messages from the
MessageGroup and pass them on in a single message with a Collection as a payload.
|
| DelegatingMessageGroupProcessor |
The
MessageGroupProcessor implementation with delegation to the provided delegate
and optional aggregation for headers. |
| ExpressionEvaluatingCorrelationStrategy |
CorrelationStrategy implementation that evaluates an expression. |
| ExpressionEvaluatingMessageGroupProcessor |
A
MessageGroupProcessor implementation that evaluates a SpEL expression. |
| ExpressionEvaluatingMessageListProcessor |
A base class for aggregators that evaluates a SpEL expression with the message list as the root object within the
evaluation context.
|
| ExpressionEvaluatingReleaseStrategy |
A
ReleaseStrategy that evaluates an expression. |
| FluxAggregatorMessageHandler |
The
AbstractMessageProducingHandler implementation for aggregation logic based
on Reactor's Flux.groupBy(java.util.function.Function<? super T, ? extends K>) and Flux.window(int) operators. |
| HeaderAttributeCorrelationStrategy |
Default implementation of
CorrelationStrategy. |
| MessageCountReleaseStrategy | |
| MessageGroupExpiredEvent |
Event representing the expiration of a message group.
|
| MessageSequenceComparator | |
| MethodInvokingCorrelationStrategy |
CorrelationStrategy implementation that works as an adapter to another bean. |
| MethodInvokingMessageGroupProcessor |
MessageGroupProcessor that serves as an adapter for the invocation of a POJO method.
|
| MethodInvokingMessageListProcessor<T> |
A MessageListProcessor implementation that invokes a method on a target POJO.
|
| MethodInvokingReleaseStrategy |
A
ReleaseStrategy that invokes a method on a plain old Java object. |
| ResequencingMessageGroupProcessor |
This class implements all the strategy interfaces needed for a default resequencer.
|
| ResequencingMessageHandler |
Resequencer specific implementation of
AbstractCorrelatingMessageHandler. |
| SequenceSizeReleaseStrategy |
An implementation of
ReleaseStrategy that simply compares the current size of
the message list to the expected 'sequenceSize'. |
| SimpleMessageGroupProcessor |
A
MessageGroupProcessor that simply returns the messages in the group. |
| SimpleSequenceSizeReleaseStrategy |
An implementation of
ReleaseStrategy that simply compares the current size of
the message list to the expected 'sequenceSize'. |
| TimeoutCountSequenceSizeReleaseStrategy |
A
ReleaseStrategy that releases all messages if any of the following is true:
The sequence is complete (if there is one).
There are more messages than a threshold set by the user.
The time elapsed since the earliest message, according to their timestamps, if
present, exceeds a timeout set by the user.
|