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 the ReleaseStrategy and used in the AbstractCorrelatingMessageHandler 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 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	A ReleaseStrategy that releases only the first n messages, where n is a threshold.
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.