org.mule.routing
Class AbstractCorrelationAggregator

java.lang.Object
  extended by org.mule.processor.AbstractInterceptingMessageProcessorBase
      extended by org.mule.processor.AbstractInterceptingMessageProcessor
          extended by org.mule.routing.AbstractAggregator
              extended by 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.


Field Summary
 
Fields inherited from class org.mule.routing.AbstractAggregator
eventCorrelator, flowConstruct, messageInfoMapping, muleContext, persistentStores, storePrefix
 
Fields inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase
logger, next, notificationHandler
 
Fields inherited from interface org.mule.api.lifecycle.Initialisable
PHASE_NAME
 
Fields inherited from interface org.mule.api.lifecycle.Startable
PHASE_NAME
 
Fields inherited from interface org.mule.api.lifecycle.Stoppable
PHASE_NAME
 
Fields inherited from interface org.mule.api.AnnotatedObject
PROPERTY_NAME
 
Constructor Summary
AbstractCorrelationAggregator()
           
 
Method Summary
protected abstract  MuleEvent aggregateEvents(EventGroup events)
           
protected  EventCorrelatorCallback getCorrelatorCallback(MuleContext muleContext)
           
 
Methods inherited from class org.mule.routing.AbstractAggregator
expireAggregation, getStorePrefix, getTimeout, initialise, isFailOnTimeout, isPersistentStores, process, setFailOnTimeout, setFlowConstruct, setMessageInfoMapping, setMuleContext, setPersistentStores, setStorePrefix, setTimeout, start, stop
 
Methods inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase
getAnnotation, getAnnotations, getListener, getMuleContext, isEventValid, processNext, setAnnotations, setListener, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.mule.api.source.MessageSource
setListener
 

Constructor Detail

AbstractCorrelationAggregator

public AbstractCorrelationAggregator()
Method Detail

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.