org.mule.routing.outbound
Class AbstractOutboundRouter
java.lang.Object
org.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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
AbstractOutboundRouter
public AbstractOutboundRouter()
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.