public class MessageChunkAggregator extends AbstractAggregator
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BUFFER_SIZE |
protected Comparator |
eventComparator |
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 |
---|
MessageChunkAggregator() |
Modifier and Type | Method and Description |
---|---|
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
public static final int DEFAULT_BUFFER_SIZE
protected Comparator eventComparator
protected EventCorrelatorCallback getCorrelatorCallback(MuleContext muleContext)
getCorrelatorCallback
in class AbstractAggregator
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.