public class ResequenceMessagesCorrelatorCallback extends CollectionCorrelatorCallback
aggregateEvents(org.mule.routing.EventGroup)
method only resequences
the events and returns an MuleEvent[] wrapped in a MuleMessage impl. This means
that this callback can ONLY be used with a Resequencer
Modifier and Type | Field and Description |
---|---|
protected Comparator |
eventComparator |
protected MuleContext |
muleContext |
logger
Constructor and Description |
---|
ResequenceMessagesCorrelatorCallback(Comparator eventComparator,
MuleContext muleContext,
boolean persistantStore,
String storePrefix) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns
true.
|
createEventGroup, getMergedSession, shouldAggregateEvents
protected Comparator eventComparator
protected MuleContext muleContext
public ResequenceMessagesCorrelatorCallback(Comparator eventComparator, MuleContext muleContext, boolean persistantStore, String storePrefix)
public MuleEvent aggregateEvents(EventGroup events) throws AggregationException
aggregateEvents
in interface EventCorrelatorCallback
aggregateEvents
in class CollectionCorrelatorCallback
events
- the event group for this requestAggregationException
- if the aggregation fails. in
this scenario the whole event group is removed and passed to the
exception handler for this componenetCopyright © 2003–2015 MuleSoft, Inc.. All rights reserved.