Package org.springframework.integration.aggregator

Interface Summary

CorrelationStrategy	Strategy for determining how messages shall be correlated.
MessageGroupProcessor	A processor for correlated groups of messages.
ReleaseStrategy	Strategy for determining when a group of messages reaches a state of completion (i.e. can trip a barrier).

Class Summary

AbstractAggregatingMessageGroupProcessor	Base class for MessageGroupProcessor implementations that aggregate the group of Messages into a single Message.
CorrelatingMessageBarrier	This Endpoint serves as a barrier for messages that should not be processed yet.
CorrelatingMessageHandler	Message handler 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.
HeaderAttributeCorrelationStrategy	Default implementation of CorrelationStrategy.
MessageCountReleaseStrategy	A ReleaseStrategy that releases only the first n messages, where n is a threshold.
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.
MethodInvokingMessageGroupProcessor	MessageGroupProcessor that serves as an adapter for the invocation of a POJO method.
PassThroughMessageGroupProcessor	This implementation of MessageGroupProcessor will forward all messages inside the group to the given output channel.
ReleaseStrategyAdapter	Adapter for methods annotated with @ReleaseStrategy and for 'release-strategy' elements that include a 'method' attribute (e.g.
ResequencingMessageGroupProcessor	This class implements all the strategy interfaces needed for a default resequencer.
SequenceNumberComparator
SequenceSizeReleaseStrategy	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).