org.springframework.integration.aggregator
Class MethodInvokingAggregator

java.lang.Object
  org.springframework.integration.handler.AbstractMessageHandler
      org.springframework.integration.aggregator.AbstractMessageBarrierHandler<java.util.List<Message<?>>>
          org.springframework.integration.aggregator.AbstractMessageAggregator
              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, resolveReplyChannel, 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