Package org.springframework.integration.aggregator

Interface Summary
Aggregator Strategy interface for aggregating a list of Messages into a single Message.
CompletionStrategy Strategy for determining when a group of messages reaches a state of completion (i.e.
MessageBarrier Common interface for routing components that release a list of Messages based upon a condition that is met when a Message arrives.
 

Class Summary
AbstractMessageBarrier Default implementation for a MessageBarrier.
AbstractMessageBarrierHandler Base class for MessageBarrier-based MessageHandlers.
AggregatingMessageHandler An AbstractMessageBarrierHandler that waits for a complete group of Messages to arrive and then delegates to an Aggregator to combine them into a single Message.
AggregationBarrier MessageBarrier implementation for message aggregation.
AggregatorAdapter Aggregator adapter for methods annotated with @Aggregator and for 'aggregator' elements that include a 'method' attribute (e.g.
AggregatorMessageHandlerCreator Creates an AggregatorAdapter for methods that aggregate messages.
CompletionStrategyAdapter Adapter for methods annotated with @CompletionStrategy and for 'completion-strategy' elements that include a 'method' attribute (e.g.
MessageSequenceComparator A Comparator implementation based on the 'sequence number' property of a Message's header.
ResequencingMessageBarrier MessageBarrier implementation for resequencing.
ResequencingMessageHandler An AbstractMessageBarrierHandler that waits for a group of Messages to arrive and re-sends them in order, sorted by their sequenceNumber.
SequenceSizeCompletionStrategy An implementation of CompletionStrategy that simply compares the current size of the message list to the expected 'sequenceSize' according to the first Message in the list.