org.mule.routing.inbound
Class AbstractEventResequencer

java.lang.Object
  extended byorg.mule.routing.inbound.SelectiveConsumer
      extended byorg.mule.routing.inbound.AbstractEventResequencer
All Implemented Interfaces:
UMOInboundRouter, UMORouter
Direct Known Subclasses:
CorrelationEventResequencer

public abstract class AbstractEventResequencer
extends SelectiveConsumer

AbstractEventResequencer is used to receive a set of events, resequence them and forward them on to their destination

Version:
$Revision: 1.1.1.1 $
Author:
Ross Mason

Field Summary
protected static Log logger
          logger used by this class
protected static java.lang.String NO_CORRELATION_ID
           
 
Constructor Summary
AbstractEventResequencer()
           
 
Method Summary
protected  EventGroup addEvent(UMOEvent event)
           
 java.util.Comparator getComparator()
           
 UMOEvent[] process(UMOEvent event)
           
protected  void removeGroup(java.lang.String id)
           
protected  java.util.List resequenceEvents(EventGroup events)
           
 void setComparator(java.util.Comparator comparator)
           
protected abstract  boolean shouldResequence(EventGroup events)
           
 
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
 

Field Detail

NO_CORRELATION_ID

protected static final java.lang.String NO_CORRELATION_ID
See Also:
Constant Field Values

logger

protected static transient Log logger
logger used by this class

Constructor Detail

AbstractEventResequencer

public AbstractEventResequencer()
Method Detail

process

public UMOEvent[] process(UMOEvent event)
                   throws RoutingException
Specified by:
process in interface UMOInboundRouter
Overrides:
process in class SelectiveConsumer
Throws:
RoutingException

addEvent

protected EventGroup addEvent(UMOEvent event)

removeGroup

protected void removeGroup(java.lang.String id)

resequenceEvents

protected java.util.List resequenceEvents(EventGroup events)

getComparator

public java.util.Comparator getComparator()

setComparator

public void setComparator(java.util.Comparator comparator)

shouldResequence

protected abstract boolean shouldResequence(EventGroup events)


Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.