org.springframework.integration.aggregator
Class MethodInvokingAggregator

java.lang.Object
  extended by org.springframework.integration.handler.AbstractMessageHandler
      extended by org.springframework.integration.aggregator.AbstractMessageBarrierHandler<java.util.List<Message<?>>>
          extended by org.springframework.integration.aggregator.AbstractMessageAggregator
              extended by org.springframework.integration.aggregator.MethodInvokingAggregator
All Implemented Interfaces:
org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.core.Ordered, MessageHandler

public class MethodInvokingAggregator
extends AbstractMessageAggregator

AbstractMessageAggregator adapter for methods annotated with @Aggregator annotation and for aggregator elements (e.g. <aggregator ref="beanReference" method="methodName"/>).

Author:
Marius Bogoevici, Mark Fisher

Field Summary
 
Fields inherited from class org.springframework.integration.aggregator.AbstractMessageBarrierHandler
barriers, DEFAULT_REAPER_INTERVAL, DEFAULT_SEND_TIMEOUT, DEFAULT_TIMEOUT, DEFAULT_TRACKED_CORRRELATION_ID_CAPACITY, logger, trackedCorrelationIds
 
Fields inherited from interface org.springframework.core.Ordered
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
 
Constructor Summary
MethodInvokingAggregator(java.lang.Object object)
           
MethodInvokingAggregator(java.lang.Object object, java.lang.reflect.Method method)
           
MethodInvokingAggregator(java.lang.Object object, java.lang.String methodName)
           
 
Method Summary
 Message<?> aggregateMessages(java.util.List<Message<?>> messages)
           
 
Methods inherited from class org.springframework.integration.aggregator.AbstractMessageAggregator
createMessageBarrier, processBarrier, setCompletionStrategy
 
Methods inherited from class org.springframework.integration.aggregator.AbstractMessageBarrierHandler
afterPropertiesSet, canAddMessage, discardBarrier, handleMessageInternal, isRunning, removeBarrier, resolveReplyChannelFromMessage, sendReplies, sendReply, setAutoStartup, setBeanFactory, setCorrelationStrategy, setDiscardChannel, setOutputChannel, setReaperInterval, setSendPartialResultOnTimeout, setSendTimeout, setTaskScheduler, setTimeout, setTrackedCorrelationIdCapacity, start, stop
 
Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler
getOrder, handleMessage, setOrder
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MethodInvokingAggregator

public MethodInvokingAggregator(java.lang.Object object,
                                java.lang.reflect.Method method)

MethodInvokingAggregator

public MethodInvokingAggregator(java.lang.Object object,
                                java.lang.String methodName)

MethodInvokingAggregator

public MethodInvokingAggregator(java.lang.Object object)
Method Detail

aggregateMessages

public Message<?> aggregateMessages(java.util.List<Message<?>> messages)
Specified by:
aggregateMessages in class AbstractMessageAggregator