org.springframework.integration.aggregator
Class PassThroughMessageGroupProcessor

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

All Implemented Interfaces:

MessageGroupProcessor

public class PassThroughMessageGroupProcessor
extends Object
implements MessageGroupProcessor

This implementation of MessageGroupProcessor will forward all messages inside the group to the given output channel. 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.

Since:

2.0.0

Author:

Iwein Fuld

Constructor Summary

PassThroughMessageGroupProcessor()

Method Summary

void	processAndSend(MessageGroup group, MessagingTemplate messagingTemplate, MessageChannel outputChannel) Process the given group and send the resulting message(s) to the output channel using the messaging template.

Methods inherited from class java.lang.Object

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

Constructor Detail

PassThroughMessageGroupProcessor

public PassThroughMessageGroupProcessor()

Method Detail

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