Package org.springframework.integration.aggregator

Interface Summary

CompletionStrategy	Strategy for determining when a group of messages reaches a state of completion (i.e.
CorrelationStrategy	Strategy for determining how messages shall be correlated.
MessageGroupListener	Listener that can be configured with a MessageGroup to receive notifications on processing of (parts of) the group and exactly one notification when the whole group completes.
MessageGroupProcessor	A processor for correlated groups of messages.

Class Summary

AbstractMessageAggregator	A base class for aggregating a group of Messages into a single Message.
AbstractMessageBarrierHandler<T extends Collection<? extends Message<?>>>	Base class for MessageBarrier-based Message Handlers.
CompletionStrategyAdapter	Adapter for methods annotated with @CompletionStrategy and for 'completion-strategy' elements that include a 'method' attribute (e.g.
CorrelatingMessageHandler	MessageHandler that holds a buffer of correlated messages in a MessageStore.
CorrelationStrategyAdapter	CorrelationStrategy implementation that works as an adapter to another bean.
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.
DefaultMessageAggregator	The Default Message Aggregator implementation that combines a group of messages into a single message containing a List of all payloads.
DefaultResequencerStrategies	This class implements all the strategy interfaces needed for a default resequencer.
HeaderAttributeCorrelationStrategy	Default implementation of CorrelationStrategy.
MessageBarrier<T extends Collection<? extends Message<?>>>	Utility class for AbstractMessageBarrierHandler and its subclasses for storing objects while in transit.
MessageGroup	Represents an mutable group of correlated messages that is bound to a certain MessageStore and correlation key.
MessageListMethodAdapter	Base class for implementing adapters for methods which take as an argument a list of Message instances or payloads.
MessageSequenceComparator	A Comparator implementation based on the 'sequence number' property of a Message's header.
MethodInvokingAggregator	AbstractMessageAggregator adapter for methods annotated with @Aggregator annotation and for aggregator elements (e.g.
MethodInvokingAggregatorFactoryBean
MethodInvokingMessageGroupProcessor
PassThroughMessageGroupProcessor	This implementation of MessageGroupProcessor will forward all messages inside the group to the given output channel.
Resequencer	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.