org.springframework.integration.aggregator
Class MethodInvokingAggregator

java.lang.Object
  org.springframework.integration.context.IntegrationObjectSupport
      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.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.core.Ordered, MessageProducer, MessageHandler, ComponentMetadataProvider

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, populateComponentMetadata, processBarrier, setCompletionStrategy

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

canAddMessage, discardBarrier, handleMessageInternal, isRunning, onInit, removeBarrier, resolveReplyChannelFromMessage, sendReplies, sendReply, setAutoStartup, 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 org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, getBeanFactory, getBeanName, getChannelResolver, getComponentMetadata, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setChannelResolver, setConversionService, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.beans.factory.BeanFactoryAware

setBeanFactory

Methods inherited from interface org.springframework.beans.factory.InitializingBean

afterPropertiesSet

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