public abstract class CorrelationAggregator extends AbstractEventAggregator
CorrelationAggregator
uses the CorrelationID and
CorrelationGroupSize properties of the MuleMessage
to manage
message groups.logger
muleContext
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
CorrelationAggregator() |
Modifier and Type | Method and Description |
---|---|
protected abstract MuleMessage |
aggregateEvents(EventGroup events) |
protected EventCorrelatorCallback |
getCorrelatorCallback() |
getTimeout, initialise, process, setTimeout
getFilter, getMessageInfoMapping, isMatch, isTransformFirst, setFilter, setMessageInfoMapping, setTransformFirst
dispose, getMuleContext, getRouterStatistics, setMuleContext, setRouterStatistics
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getRouterStatistics, setRouterStatistics
dispose
protected EventCorrelatorCallback getCorrelatorCallback()
getCorrelatorCallback
in class AbstractEventAggregator
protected abstract MuleMessage aggregateEvents(EventGroup events) throws AggregationException
AggregationException
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.