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.3 $
- Author:
- Ross Mason
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
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
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.