org.springframework.integration.aggregator
Class MethodInvokingAggregator

java.lang.Object
  org.springframework.integration.handler.AbstractMessageHandler
      org.springframework.integration.aggregator.AbstractMessageBarrierHandler
          org.springframework.integration.aggregator.AbstractMessageAggregator
              org.springframework.integration.aggregator.MethodInvokingAggregator

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean, MessageHandler, TaskSchedulerAware

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

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, isBarrierRemovable, processReleasedMessages, setCompletionStrategy

Methods inherited from class org.springframework.integration.aggregator.AbstractMessageBarrierHandler

afterPropertiesSet, handleMessageInternal, isRunning, resolveReplyChannelFromMessage, setDiscardChannel, setOutputChannel, setReaperInterval, setSendPartialResultOnTimeout, setSendTimeout, setTaskScheduler, setTimeout, setTrackedCorrelationIdCapacity, start, stop

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

handleMessage

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