org.springframework.integration.aggregator
Class ResequencingMessageGroupProcessor
java.lang.Object
org.springframework.integration.aggregator.ResequencingMessageGroupProcessor
- All Implemented Interfaces:
- MessageGroupProcessor
public class ResequencingMessageGroupProcessor
- extends Object
- implements MessageGroupProcessor
This class implements all the strategy interfaces needed for a default resequencer.
- Since:
- 2.0
- Author:
- Iwein Fuld, Dave Syer
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ResequencingMessageGroupProcessor
public ResequencingMessageGroupProcessor()
setComparator
public void setComparator(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,
MessagingTemplate messagingTemplate,
MessageChannel outputChannel)
- Description copied from interface:
MessageGroupProcessor
- Process the given group and send the resulting message(s) to the output channel using the messaging 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
Copyright © 2010. All Rights Reserved.