|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mule.routing.inbound.SelectiveConsumer
org.mule.routing.inbound.AbstractEventAggregator
org.mule.routing.inbound.CorrelationAggregator
CorrelationAggregator
Uses the CorrelationID and CorrelationGroupSize
properties of the UMOMessage
to manage message groups.
Field Summary |
Fields inherited from class org.mule.routing.inbound.AbstractEventAggregator |
eventGroups, NO_CORRELATION_ID |
Fields inherited from class org.mule.routing.inbound.SelectiveConsumer |
logger |
Constructor Summary | |
CorrelationAggregator()
|
Method Summary | |
protected EventGroup |
addEvent(UMOEvent event)
Adds the event to an event group. |
protected boolean |
shouldAggregate(EventGroup events)
Determines if the event group is ready to be aggregated. |
Methods inherited from class org.mule.routing.inbound.AbstractEventAggregator |
aggregateEvents, process, removeGroup |
Methods inherited from class org.mule.routing.inbound.SelectiveConsumer |
getFilter, getRouterStatistics, isMatch, isTransformFirst, setFilter, setRouterStatistics, setTransformFirst |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public CorrelationAggregator()
Method Detail |
protected boolean shouldAggregate(EventGroup events)
shouldAggregate
in class AbstractEventAggregator
events
-
protected EventGroup addEvent(UMOEvent event)
addEvent
in class AbstractEventAggregator
event
-
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |