org.mule.routing.inbound
Class CorrelationAggregator
java.lang.Object
org.mule.routing.inbound.SelectiveConsumer
org.mule.routing.inbound.AbstractEventAggregator
org.mule.routing.inbound.CorrelationAggregator
- All Implemented Interfaces:
- UMOInboundRouter, UMORouter
- Direct Known Subclasses:
- BankQuotesAggregator, MessageChunkingAggregator
- public abstract class CorrelationAggregator
- extends AbstractEventAggregator
CorrelationAggregator Uses the CorrelationID and
CorrelationGroupSize properties of the UMOMessage to manage
message groups.
- Version:
- $Revision: 3798 $
- Author:
- Ross Mason
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CorrelationAggregator
public CorrelationAggregator()
shouldAggregate
protected boolean shouldAggregate(EventGroup events)
- Determines if the event group is ready to be aggregated. if the group is ready
to be aggregated (this is entirely up to the application. it could be
determined by volume, last modified time or some oher criteria based on the
last event received)
- Specified by:
shouldAggregate in class AbstractEventAggregator
- Parameters:
events -
- Returns:
addEvent
protected EventGroup addEvent(UMOEvent event)
- Adds the event to an event group. Groups are defined by the correlationId on
the message. If no correlationId is set a default group is created for all
events without a correlationId. If there is no group for the current
correlationId one will be created and added to the router.
- Overrides:
addEvent in class AbstractEventAggregator
- Parameters:
event -
- Returns:
Copyright © 2003-2006 MuleSource Inc.. All Rights Reserved.