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.7 $
Author:
Ross Mason

Field Summary
static int ENABLE_CORREATION_ALWAYS
           
static int ENABLE_CORREATION_IF_NOT_SET
           
static int ENABLE_CORREATION_NEVER
           
protected  int enableCorrelation
           
protected  java.util.List endpoints
           
protected  Log logger
          logger used by this class
protected  PropertyExtractor propertyExtractor
           
protected  java.lang.String replyTo
           
protected  RouterStatistics routerStatistics
           
protected  UMOTransactionConfig transactionConfig
           
 
Constructor Summary
AbstractOutboundRouter()
           
 
Method Summary
 void addEndpoint(UMOEndpoint endpoint)
           
 void dispatch(UMOSession session, UMOMessage message, UMOEndpoint endpoint)
           
 int getEnableCorrelation()
           
 java.util.List getEndpoints()
           
 PropertyExtractor getPropertyExtractor()
           
 java.lang.String getReplyTo()
           
 RouterStatistics getRouterStatistics()
           
 UMOTransactionConfig getTransactionConfig()
           
 boolean removeEndpoint(UMOEndpoint endpoint)
           
 UMOMessage send(UMOSession session, UMOMessage message, UMOEndpoint endpoint)
           
 void setEnableCorrelation(int enableCorrelation)
           
 void setEnableCorrelationAsString(java.lang.String enableCorrelation)
           
 void setEndpoints(java.util.List endpoints)
           
protected  void setMessageProperties(UMOSession session, UMOMessage message, UMOEndpoint endpoint)
           
 void setPropertyExtractor(PropertyExtractor propertyExtractor)
           
 void setReplyTo(java.lang.String replyTo)
           
 void setRouterStatistics(RouterStatistics routerStatistics)
           
 void setTransactionConfig(UMOTransactionConfig transactionConfig)
           
 
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

ENABLE_CORREATION_IF_NOT_SET

public static final int ENABLE_CORREATION_IF_NOT_SET
See Also:
Constant Field Values

ENABLE_CORREATION_ALWAYS

public static final int ENABLE_CORREATION_ALWAYS
See Also:
Constant Field Values

ENABLE_CORREATION_NEVER

public static final int ENABLE_CORREATION_NEVER
See Also:
Constant Field Values

logger

protected transient Log logger
logger used by this class


endpoints

protected java.util.List endpoints

replyTo

protected java.lang.String replyTo

enableCorrelation

protected int enableCorrelation

propertyExtractor

protected PropertyExtractor propertyExtractor

routerStatistics

protected RouterStatistics routerStatistics

transactionConfig

protected UMOTransactionConfig transactionConfig
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

getEnableCorrelation

public int getEnableCorrelation()

setEnableCorrelation

public void setEnableCorrelation(int enableCorrelation)

setEnableCorrelationAsString

public void setEnableCorrelationAsString(java.lang.String enableCorrelation)

getPropertyExtractor

public PropertyExtractor getPropertyExtractor()

setPropertyExtractor

public void setPropertyExtractor(PropertyExtractor propertyExtractor)

getTransactionConfig

public UMOTransactionConfig getTransactionConfig()
Specified by:
getTransactionConfig in interface UMOOutboundRouter

setTransactionConfig

public void setTransactionConfig(UMOTransactionConfig transactionConfig)
Specified by:
setTransactionConfig in interface UMOOutboundRouter


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