Class ResequenceCorrelatorCallback

  extended by org.mule.routing.CollectionCorrelatorCallback
      extended by org.mule.routing.ResequenceCorrelatorCallback
All Implemented Interfaces:

public class ResequenceCorrelatorCallback
extends CollectionCorrelatorCallback

A Correlator that correlates messages based on Mule correlation settings Note that the aggregateEvents(org.mule.routing.inbound.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 CorrelationEventResequencer

Field Summary
protected  Comparator eventComparator
protected  Log logger
          logger used by this class
Constructor Summary
ResequenceCorrelatorCallback(Comparator eventComparator)
Method Summary
 MuleMessage aggregateEvents(EventGroup events)
          This method is invoked if the shouldAggregate method is called and returns true.
Methods inherited from class org.mule.routing.CollectionCorrelatorCallback
createEventGroup, shouldAggregateEvents
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
logger used by this class


protected Comparator eventComparator
Constructor Detail


public ResequenceCorrelatorCallback(Comparator eventComparator)
Method Detail


public MuleMessage aggregateEvents(EventGroup events)
                            throws AggregationException
This method is invoked if the shouldAggregate method is called and returns true. Once this method returns an aggregated message, the event group is removed from the router.

Specified by:
aggregateEvents in interface EventCorrelatorCallback
aggregateEvents in class CollectionCorrelatorCallback
events - the event group for this request
an aggregated message
AggregationException - if the aggregation fails. in this scenario the whole event group is removed and passed to the exception handler for this componenet

Copyright © 2003-2009 MuleSource, Inc.. All Rights Reserved.