public abstract class AbstractCorrelationAggregator extends AbstractAggregator
AbstractCorrelationAggregatingMessageProcessor
uses the CorrelationID
and CorrelationGroupSize properties of the MuleMessage
to
manage message groups.eventCorrelator, EVENTS_STORE_REGISTRY_KEY_PREFIX, eventsObjectStoreKey, flowConstruct, MAX_PROCESSED_GROUPS, messageInfoMapping, muleContext, persistentStores, storePrefix
logger, next, notificationHandler
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
AbstractCorrelationAggregator() |
Modifier and Type | Method and Description |
---|---|
protected abstract MuleEvent |
aggregateEvents(EventGroup events) |
protected EventCorrelatorCallback |
getCorrelatorCallback(MuleContext muleContext) |
dispose, expireAggregation, getStorePrefix, getTimeout, initEventGroupsObjectStore, initialise, initProcessedGroupsObjectStore, internalEventsGroupsObjectStoreFactory, internalProcessedGroupsObjectStoreFactory, isFailOnTimeout, isPersistentStores, process, setEventGroupsObjectStore, setFailOnTimeout, setFlowConstruct, setMessageInfoMapping, setMuleContext, setPersistentStores, setProcessedGroupsObjectStore, setStorePrefix, setTimeout, start, stop
addMessageProcessorPathElements, getListener, getMuleContext, isEventValid, processNext, setListener, toString
getAnnotation, getAnnotations, setAnnotations
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setListener
protected EventCorrelatorCallback getCorrelatorCallback(MuleContext muleContext)
getCorrelatorCallback
in class AbstractAggregator
protected abstract MuleEvent aggregateEvents(EventGroup events) throws AggregationException
AggregationException
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.