Package | Description |
---|---|
org.mule.routing |
Defines the core routing patterns supported by mule.
|
org.mule.routing.correlation |
Modifier and Type | Method and Description |
---|---|
protected abstract EventCorrelatorCallback |
AbstractAggregator.getCorrelatorCallback(MuleContext muleContext) |
protected EventCorrelatorCallback |
MessageChunkAggregator.getCorrelatorCallback(MuleContext muleContext) |
protected EventCorrelatorCallback |
Resequencer.getCorrelatorCallback(MuleContext muleContext) |
protected EventCorrelatorCallback |
SimpleCollectionAggregator.getCorrelatorCallback(MuleContext muleContext) |
protected EventCorrelatorCallback |
AbstractCorrelationAggregator.getCorrelatorCallback(MuleContext muleContext) |
Modifier and Type | Class and Description |
---|---|
class |
CollectionCorrelatorCallback
A Correlator that correlates messages based on Mule correlation settings
|
class |
ResequenceCorrelatorCallback
A Correlator that correlates messages based on Mule correlation settings.
|
class |
ResequenceMessagesCorrelatorCallback
A Correlator that correlates messages based on Mule correlation settings Note that
the
ResequenceMessagesCorrelatorCallback.aggregateEvents(org.mule.routing.EventGroup) method only resequences
the events and returns an MuleEvent[] wrapped in a MuleMessage impl. |
Constructor and Description |
---|
EventCorrelator(EventCorrelatorCallback callback,
MessageProcessor timeoutMessageProcessor,
MessageInfoMapping messageInfoMapping,
MuleContext muleContext,
FlowConstruct flowConstruct,
PartitionableObjectStore correlatorStore,
String storePrefix,
ObjectStore<Long> processedGroups) |
Copyright © 2003–2018 MuleSoft, Inc.. All rights reserved.