org.springframework.integration.aggregator
Class ResequencingMessageGroupProcessor

java.lang.Object
  org.springframework.integration.aggregator.ResequencingMessageGroupProcessor

All Implemented Interfaces:

MessageGroupProcessor

public class ResequencingMessageGroupProcessor
extends java.lang.Object
implements MessageGroupProcessor

This class implements all the strategy interfaces needed for a default resequencer.

Since:

2.0

Author:

Iwein Fuld, Dave Syer

Constructor Summary

ResequencingMessageGroupProcessor()

Method Summary

void	processAndSend(MessageGroup group, MessageChannelTemplate channelTemplate, MessageChannel outputChannel) Process the given group and send the resulting message(s) to the output channel using the channel template.
void	setComparator(java.util.Comparator<Message<?>> comparator) A comparator to use to order messages before processing.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ResequencingMessageGroupProcessor

public ResequencingMessageGroupProcessor()

Method Detail

setComparator

public void setComparator(java.util.Comparator<Message<?>> comparator)

A comparator to use to order messages before processing. The default is to order by sequence number.

Parameters:

comparator - the comparator to use to order messages

processAndSend

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

Description copied from interface: MessageGroupProcessor

Process the given group and send the resulting message(s) to the output channel using the channel template. Implementations are free to send as little or as many messages based on the invocation as needed. For example an aggregating processor will send only a single message representing the group, where a resequencing strategy will send all messages in the group individually.

Specified by:

processAndSend in interface MessageGroupProcessor