org.springframework.integration.aggregator
Class PassThroughMessageGroupProcessor

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

All Implemented Interfaces:

MessageGroupProcessor

public class PassThroughMessageGroupProcessor
extends java.lang.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 CompletionStrategy lets them pass through.

Since:

2.0.0

Author:

Iwein Fuld

Constructor Summary

PassThroughMessageGroupProcessor()

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.

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,
                           MessageChannelTemplate channelTemplate,
                           MessageChannel outputChannel)

Description copied from interface: MessageGroupProcessor

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.

Specified by:

processAndSend in interface MessageGroupProcessor