public static class AggregatorTestCase.TestEventAggregator extends AbstractAggregator
Modifier and Type | Field and Description |
---|---|
protected int |
eventCount |
protected int |
eventThreshold |
eventCorrelator, flowConstruct, messageInfoMapping, muleContext, persistentStores, storePrefix
logger, next, notificationHandler
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
AggregatorTestCase.TestEventAggregator(int eventThreshold) |
Modifier and Type | Method and Description |
---|---|
protected EventCorrelatorCallback |
getCorrelatorCallback(MuleContext muleContext) |
dispose, expireAggregation, getStorePrefix, getTimeout, initialise, isFailOnTimeout, isPersistentStores, process, setFailOnTimeout, setFlowConstruct, setMessageInfoMapping, setMuleContext, setPersistentStores, setStorePrefix, setTimeout, start, stop
addMessageProcessorPathElements, getAnnotation, getAnnotations, getListener, getMuleContext, isEventValid, processNext, setAnnotations, setListener, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setListener
public AggregatorTestCase.TestEventAggregator(int eventThreshold)
protected EventCorrelatorCallback getCorrelatorCallback(MuleContext muleContext)
getCorrelatorCallback
in class AbstractAggregator
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.