public abstract class AbstractRecipientList extends FilteringOutboundRouter
AbstractRecipientList
is used to dispatch a single event to
multiple recipients over the same transport. The recipient endpoints can be
configured statically or can be obtained from the message payload.Modifier and Type | Field and Description |
---|---|
protected org.apache.commons.logging.Log |
logger
logger used by this class
|
ENABLE_CORRELATION_ALWAYS, ENABLE_CORRELATION_IF_NOT_SET, ENABLE_CORRELATION_NEVER, enableCorrelation, endpoints, messageInfoMapping, replyTo, transactionConfig
muleContext
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
AbstractRecipientList() |
Modifier and Type | Method and Description |
---|---|
protected OutboundEndpoint |
getRecipientEndpoint(MuleMessage message,
Object recipient) |
protected OutboundEndpoint |
getRecipientEndpointFromString(MuleMessage message,
String recipient) |
protected OutboundEndpoint |
getRecipientEndpointFromUri(EndpointURI uri) |
protected abstract List |
getRecipients(MuleMessage message) |
Boolean |
getSynchronous() |
boolean |
isDynamicEndpoints()
Determines whether this router supports dynamic endpoint.
|
MuleMessage |
route(MuleMessage message,
MuleSession session,
boolean synchronous)
This method is responsible for routing the Message via the MuleSession.
|
void |
setSynchronous(Boolean synchronous) |
addEndpoint, getEndpoint, getFilter, getTransformers, isMatch, isUseTemplates, setFilter, setTransformers, setUseTemplates
createTransactionTemplate, dispatch, getEnableCorrelation, getEndpoint, getEndpoints, getMessageInfoMapping, getReplyTo, getTransactionConfig, removeEndpoint, send, setEnableCorrelation, setEnableCorrelationAsString, setEndpoints, setMessageInfoMapping, setMessageProperties, setReplyTo, setTransactionConfig
dispose, getMuleContext, getRouterStatistics, initialise, setMuleContext, setRouterStatistics
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getRouterStatistics, setRouterStatistics
initialise
dispose
public MuleMessage route(MuleMessage message, MuleSession session, boolean synchronous) throws RoutingException
OutboundRouter
route
in interface OutboundRouter
route
in class FilteringOutboundRouter
message
- the message to send via one or more endpoints on this routersession
- the session used to actually send the eventsynchronous
- whether the invocation process should be synchronous or notRoutingException
FilteringOutboundRouter
,
ExceptionBasedRouter
,
MulticastingRouter
protected OutboundEndpoint getRecipientEndpoint(MuleMessage message, Object recipient) throws RoutingException
RoutingException
protected OutboundEndpoint getRecipientEndpointFromUri(EndpointURI uri) throws MuleException
MuleException
protected OutboundEndpoint getRecipientEndpointFromString(MuleMessage message, String recipient) throws MuleException
MuleException
public Boolean getSynchronous()
public void setSynchronous(Boolean synchronous)
public boolean isDynamicEndpoints()
OutboundRouter
isDynamicEndpoints
in interface OutboundRouter
isDynamicEndpoints
in class AbstractOutboundRouter
protected abstract List getRecipients(MuleMessage message)
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.