public static class AggregationTestCase.Aggregator extends SimpleCollectionAggregator
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 |
---|
AggregationTestCase.Aggregator() |
Modifier and Type | Method and Description |
---|---|
protected EventCorrelatorCallback |
getCorrelatorCallback(MuleContext context) |
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 context)
getCorrelatorCallback
in class SimpleCollectionAggregator
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.