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)

Method Summary

void	processAndSend(java.lang.Object correlationKey, java.util.Collection<Message<?>> messagesUpForProcessing, MessageChannel outputChannel, BufferedMessagesCallback processedCallback)
java.util.Set<java.lang.reflect.Method>	removeMethodsMatchingSelector(java.util.Set<java.lang.reflect.Method> candidates, org.springframework.integration.aggregator.MethodInvokingMessageGroupProcessor.MethodSelector selector)

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)

Method Detail

processAndSend

public void processAndSend(java.lang.Object correlationKey,
                           java.util.Collection<Message<?>> messagesUpForProcessing,
                           MessageChannel outputChannel,
                           BufferedMessagesCallback processedCallback)

Specified by:

processAndSend in interface MessageGroupProcessor

removeMethodsMatchingSelector

public java.util.Set<java.lang.reflect.Method> removeMethodsMatchingSelector(java.util.Set<java.lang.reflect.Method> candidates,
                                                                             org.springframework.integration.aggregator.MethodInvokingMessageGroupProcessor.MethodSelector selector)