Class PassThroughMessageGroupProcessor

  extended by org.springframework.integration.aggregator.PassThroughMessageGroupProcessor
All Implemented Interfaces:

public class PassThroughMessageGroupProcessor
extends java.lang.Object
implements MessageGroupProcessor

This implementation of MessageGroupProcessor will return all unmarked messages inside the group. This is useful if there is no requirement to process the messages, but they should just be blocked as a group until their ReleaseStrategy lets them pass through.


Constructor Summary
Method Summary
 java.lang.Object processMessageGroup(MessageGroup group)
          Process the given MessageGroup.
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail


public PassThroughMessageGroupProcessor()
Method Detail


public java.lang.Object processMessageGroup(MessageGroup group)
Description copied from interface: MessageGroupProcessor
Process the given MessageGroup. Implementations are free to return as few or as many messages based on the invocation as needed. For example an aggregating processor will return only a single message representing the group, while a resequencing processor will return all messages whose preceding sequence has been satisfied.

If a multiple messages are returned the return value must be a Collection<Message>.

Specified by:
processMessageGroup in interface MessageGroupProcessor