public class TestCorrelationAggregator extends AbstractCorrelationAggregator
TestResponseAggregator
is a mock response Agrregator object used for
testing configurationeventCorrelator, 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 |
---|
TestCorrelationAggregator() |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
aggregateEvents(EventGroup events) |
String |
getTestProperty() |
void |
setTestProperty(String testProperty) |
getCorrelatorCallback
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 MuleEvent aggregateEvents(EventGroup events) throws AggregationException
aggregateEvents
in class AbstractCorrelationAggregator
AggregationException
public String getTestProperty()
public void setTestProperty(String testProperty)
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.