org.mule.routing
Class AbstractCorrelationAggregator
java.lang.Object
org.mule.processor.AbstractInterceptingMessageProcessorBase
org.mule.processor.AbstractInterceptingMessageProcessor
org.mule.routing.AbstractAggregator
org.mule.routing.AbstractCorrelationAggregator
- All Implemented Interfaces:
- AnnotatedObject, FlowConstructAware, MuleContextAware, Initialisable, Startable, Stoppable, InterceptingMessageProcessor, MessageProcessor, Aggregator, MessageSource
- Direct Known Subclasses:
- BankQuotesInboundAggregator
public abstract class AbstractCorrelationAggregator
- extends AbstractAggregator
AbstractCorrelationAggregatingMessageProcessor
uses the CorrelationID
and CorrelationGroupSize properties of the MuleMessage
to
manage message groups.
Methods inherited from class org.mule.routing.AbstractAggregator |
expireAggregation, getStorePrefix, getTimeout, initialise, isFailOnTimeout, isPersistentStores, process, setFailOnTimeout, setFlowConstruct, setMessageInfoMapping, setMuleContext, setPersistentStores, setStorePrefix, setTimeout, start, stop |
AbstractCorrelationAggregator
public AbstractCorrelationAggregator()
getCorrelatorCallback
protected EventCorrelatorCallback getCorrelatorCallback(MuleContext muleContext)
- Specified by:
getCorrelatorCallback
in class AbstractAggregator
aggregateEvents
protected abstract MuleEvent aggregateEvents(EventGroup events)
throws AggregationException
- Throws:
AggregationException
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.