org.springframework.integration.aggregator
Class MethodInvokingMessageGroupProcessor

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

All Implemented Interfaces:

MessageGroupProcessor

public class MethodInvokingMessageGroupProcessor
extends java.lang.Object
implements MessageGroupProcessor

Constructor Summary

MethodInvokingMessageGroupProcessor(java.lang.Object target)

MethodInvokingMessageGroupProcessor(java.lang.Object target, java.lang.String method)

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

MethodInvokingMessageGroupProcessor

public MethodInvokingMessageGroupProcessor(java.lang.Object target)

MethodInvokingMessageGroupProcessor

public MethodInvokingMessageGroupProcessor(java.lang.Object target,
                                           java.lang.String method)

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