org.mule.routing.outbound
Class AbstractOutboundRouter

java.lang.Object
  extended byorg.mule.routing.outbound.AbstractOutboundRouter
All Implemented Interfaces:
UMOOutboundRouter, UMORouter
Direct Known Subclasses:
FilteringOutboundRouter

public abstract class AbstractOutboundRouter
extends java.lang.Object
implements UMOOutboundRouter

AbstractOutboundRouter is a base router class that tracks statics about message processing through the router.

Version:
$Revision: 1.3 $
Author:
Ross Mason

Field Summary
protected  PropertyExtractor correlationGroupExtractor
           
protected  boolean correlationId
           
protected  PropertyExtractor correlationIdExtractor
           
protected  PropertyExtractor correlationSequenceExtractor
           
protected  java.util.List endpoints
           
protected  Log logger
          logger used by this class
protected  java.lang.String replyTo
           
protected  RouterStatistics routerStatistics
           
 
Constructor Summary
AbstractOutboundRouter()
           
 
Method Summary
 void addEndpoint(UMOEndpoint endpoint)
           
 void dispatch(UMOSession session, UMOMessage message, UMOEndpoint endpoint)
           
 PropertyExtractor getCorrelationGroupExtractor()
           
 PropertyExtractor getCorrelationIdExtractor()
           
 PropertyExtractor getCorrelationSequenceExtractor()
           
 java.util.List getEndpoints()
           
 java.lang.String getReplyTo()
           
 RouterStatistics getRouterStatistics()
           
 boolean isCorrelationId()
           
 boolean removeEndpoint(UMOEndpoint endpoint)
           
 UMOMessage send(UMOSession session, UMOMessage message, UMOEndpoint endpoint)
           
 void setCorrelationGroupExtractor(PropertyExtractor correlationGroupExtractor)
           
 void setCorrelationId(boolean correlationId)
           
 void setCorrelationIdExtractor(PropertyExtractor correlationIdExtractor)
           
 void setCorrelationSequenceExtractor(PropertyExtractor correlationSequenceExtractor)
           
 void setEndpoints(java.util.List endpoints)
           
protected  void setMessageProperties(UMOSession session, UMOMessage message, UMOEndpoint endpoint)
           
 void setReplyTo(java.lang.String replyTo)
           
 void setRouterStatistics(RouterStatistics routerStatistics)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.mule.umo.routing.UMOOutboundRouter
isMatch, route
 

Field Detail

logger

protected transient Log logger
logger used by this class


endpoints

protected java.util.List endpoints

replyTo

protected java.lang.String replyTo

correlationId

protected boolean correlationId

correlationIdExtractor

protected PropertyExtractor correlationIdExtractor

correlationSequenceExtractor

protected PropertyExtractor correlationSequenceExtractor

correlationGroupExtractor

protected PropertyExtractor correlationGroupExtractor

routerStatistics

protected RouterStatistics routerStatistics
Constructor Detail

AbstractOutboundRouter

public AbstractOutboundRouter()
Method Detail

dispatch

public void dispatch(UMOSession session,
                     UMOMessage message,
                     UMOEndpoint endpoint)
              throws UMOException
Throws:
UMOException

send

public UMOMessage send(UMOSession session,
                       UMOMessage message,
                       UMOEndpoint endpoint)
                throws UMOException
Throws:
UMOException

setMessageProperties

protected void setMessageProperties(UMOSession session,
                                    UMOMessage message,
                                    UMOEndpoint endpoint)
                             throws UniqueIdNotSupportedException
Throws:
UniqueIdNotSupportedException

getEndpoints

public java.util.List getEndpoints()
Specified by:
getEndpoints in interface UMOOutboundRouter

setEndpoints

public void setEndpoints(java.util.List endpoints)
Specified by:
setEndpoints in interface UMOOutboundRouter

addEndpoint

public void addEndpoint(UMOEndpoint endpoint)
Specified by:
addEndpoint in interface UMOOutboundRouter

removeEndpoint

public boolean removeEndpoint(UMOEndpoint endpoint)
Specified by:
removeEndpoint in interface UMOOutboundRouter

getReplyTo

public java.lang.String getReplyTo()

setReplyTo

public void setReplyTo(java.lang.String replyTo)

getRouterStatistics

public RouterStatistics getRouterStatistics()
Specified by:
getRouterStatistics in interface UMORouter

setRouterStatistics

public void setRouterStatistics(RouterStatistics routerStatistics)
Specified by:
setRouterStatistics in interface UMORouter

isCorrelationId

public boolean isCorrelationId()

setCorrelationId

public void setCorrelationId(boolean correlationId)

getCorrelationIdExtractor

public PropertyExtractor getCorrelationIdExtractor()

setCorrelationIdExtractor

public void setCorrelationIdExtractor(PropertyExtractor correlationIdExtractor)

getCorrelationSequenceExtractor

public PropertyExtractor getCorrelationSequenceExtractor()

setCorrelationSequenceExtractor

public void setCorrelationSequenceExtractor(PropertyExtractor correlationSequenceExtractor)

getCorrelationGroupExtractor

public PropertyExtractor getCorrelationGroupExtractor()

setCorrelationGroupExtractor

public void setCorrelationGroupExtractor(PropertyExtractor correlationGroupExtractor)


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