Package org.springframework.integration.aggregator
Provides classes related to message aggregation.
-
Interface Summary Interface Description CorrelationStrategy Strategy for determining how messages can be correlated.GroupConditionProvider A contract which can be implemented on theReleaseStrategy
and used in theAbstractCorrelatingMessageHandler
to populate the provided group condition supplier.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 Summary 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 aMessageStore
.AbstractCorrelatingMessageHandler.SequenceAwareMessageGroup AggregatingMessageHandler Aggregator specific implementation ofAbstractCorrelatingMessageHandler
.BarrierMessageHandler A message handler that suspends the thread until a message with corresponding correlation is passed into thetrigger
method or the timeout occurs.CorrelatingMessageBarrier This Endpoint serves as a barrier for messages that should not be processed yet.DefaultAggregateHeadersFunction TheFunction
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 TheMessageGroupProcessor
implementation with delegation to the provideddelegate
and optional aggregation for headers.ExpressionEvaluatingCorrelationStrategy CorrelationStrategy
implementation that evaluates an expression.ExpressionEvaluatingMessageGroupProcessor AMessageGroupProcessor
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 AReleaseStrategy
that evaluates an expression.FluxAggregatorMessageHandler TheAbstractMessageProducingHandler
implementation for aggregation logic based on Reactor'sFlux.groupBy(java.util.function.Function<? super T, ? extends K>)
andFlux.window(int)
operators.HeaderAttributeCorrelationStrategy Default implementation ofCorrelationStrategy
.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 AReleaseStrategy
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 ofAbstractCorrelatingMessageHandler
.SequenceSizeReleaseStrategy An implementation ofReleaseStrategy
that simply compares the current size of the message list to the expected 'sequenceSize'.SimpleMessageGroupProcessor AMessageGroupProcessor
that simply returns the messages in the group.SimpleSequenceSizeReleaseStrategy An implementation ofReleaseStrategy
that simply compares the current size of the message list to the expected 'sequenceSize'.TimeoutCountSequenceSizeReleaseStrategy AReleaseStrategy
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.