|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.mule.routing.correlation.CollectionCorrelatorCallback
public class CollectionCorrelatorCallback
A Correlator that correlates messages based on Mule correlation settings
Field Summary | |
---|---|
protected Log |
logger
logger used by this class |
protected MuleContext |
muleContext
|
Constructor Summary | |
---|---|
CollectionCorrelatorCallback(MuleContext muleContext,
boolean persistantStores,
String storePrefix)
|
Method Summary | |
---|---|
MuleEvent |
aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns true. |
EventGroup |
createEventGroup(MuleEvent event,
Object groupId)
Creates a new EventGroup that will expect the number of events as returned by MuleMessage.getCorrelationGroupSize() . |
protected MuleSession |
getMergedSession(MuleEvent[] events)
|
boolean |
shouldAggregateEvents(EventGroup events)
Determines if the event group is ready to be aggregated. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final transient Log logger
protected MuleContext muleContext
Constructor Detail |
---|
public CollectionCorrelatorCallback(MuleContext muleContext, boolean persistantStores, String storePrefix)
Method Detail |
---|
public MuleEvent aggregateEvents(EventGroup events) throws AggregationException
aggregateEvents
in interface EventCorrelatorCallback
events
- the event group for this request
AggregationException
- if the aggregation fails. in this scenario the whole
event group is removed and passed to the exception handler for this componenetprotected MuleSession getMergedSession(MuleEvent[] events)
public EventGroup createEventGroup(MuleEvent event, Object groupId)
MuleMessage.getCorrelationGroupSize()
.
createEventGroup
in interface EventCorrelatorCallback
event
- the current eventgroupId
- The group id
public boolean shouldAggregateEvents(EventGroup events)
EventCorrelatorCallback
shouldAggregateEvents
in interface EventCorrelatorCallback
events
- The current event group received by the correlator
true
if the correlation size is not set or exactly the expected size of the event
group.EventCorrelatorCallback.shouldAggregateEvents(org.mule.routing.EventGroup)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |