org.springframework.integration.aggregator
Interface MessageGroupProcessor

All Known Implementing Classes:

DefaultAggregatingMessageGroupProcessor, DefaultResequencerStrategies, MethodInvokingMessageGroupProcessor, PassThroughMessageGroupProcessor

public interface MessageGroupProcessor

A processor for correlated groups of messages. When a message group is complete it is passed to the processor by e.g. the CorrelatingMessageHandler.

Author:

Iwein Fuld

See Also:

CorrelatingMessageHandler

Method Summary

void	processAndSend(MessageGroup group, MessageChannelTemplate channelTemplate, MessageChannel outputChannel) Processed the given group and sends the resulting message(s) to the output channel using the channelTemplate.

Method Detail

processAndSend

void processAndSend(MessageGroup group,
                    MessageChannelTemplate channelTemplate,
                    MessageChannel outputChannel)

Processed the given group and sends the resulting message(s) to the output channel using the channelTemplate. Implementations are free to send as little or as many messages based on the invocation as needed. For example the DefaultAggregatingMessageGroupProcessor will send only a single message containing a collection of all messages in the group, where the resequencing equivalent strategy will send all messages in the group individually.