public abstract class AbstractRecipientList extends FilteringOutboundRouter
AbstractRecipientList
is used to dispatch a single event to
multiple recipients over the same transport. The recipient targets can be
configured statically or can be obtained from the message payload.expressionManager
enableCorrelation, initialised, logger, replyTo, resultsHandler, routes, started, transactionConfig
flowConstruct, messagingExceptionHandler, muleContext
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
AbstractRecipientList() |
Modifier and Type | Method and Description |
---|---|
protected OutboundEndpoint |
buildOutboundEndpoint(String recipient) |
protected OutboundEndpoint |
getRecipientEndpoint(MuleMessage message,
Object recipient) |
protected OutboundEndpoint |
getRecipientEndpointFromString(MuleMessage message,
String recipient) |
protected OutboundEndpoint |
getRecipientEndpointFromUri(EndpointURI uri) |
protected abstract List<Object> |
getRecipients(MuleEvent event) |
Boolean |
getSynchronous() |
boolean |
isDynamicRoutes()
Determines whether this router supports dynamic route.
|
MuleEvent |
route(MuleEvent event) |
void |
setSynchronous(Boolean synchronous) |
addRoute, getFilter, getRoute, getTransformers, initialise, isMatch, isTransformBeforeMatch, isUseTemplates, setFilter, setTransformers, setUseTemplates
cloneMessage, cloneMessage, createEventToRoute, dispose, doProcessRoute, getEnableCorrelation, getMuleContext, getOwnedMessageProcessors, getReplyTo, getResultsHandler, getRoute, getRouterStatistics, getRoutes, getTransactionConfig, process, propagateMagicProperties, removeRoute, sendRequest, sendRequestEvent, setEnableCorrelation, setEnableCorrelationAsString, setMessageProcessors, setMessageProperties, setReplyTo, setResultsHandler, setRouterStatistics, setRoutes, setTransactionConfig, start, stop
addMessageProcessorPathElements, getAnnotation, getAnnotations, getOwnedObjects, setAnnotations
getFlowConstruct, getMessagingExceptionHandler, setFlowConstruct, setMessagingExceptionHandler, setMuleContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setMuleContext
setFlowConstruct
public MuleEvent route(MuleEvent event) throws RoutingException
route
in class FilteringOutboundRouter
RoutingException
protected OutboundEndpoint getRecipientEndpoint(MuleMessage message, Object recipient) throws MuleException
MuleException
protected OutboundEndpoint getRecipientEndpointFromUri(EndpointURI uri) throws MuleException
MuleException
protected OutboundEndpoint getRecipientEndpointFromString(MuleMessage message, String recipient) throws MuleException
MuleException
protected OutboundEndpoint buildOutboundEndpoint(String recipient) throws MuleException
MuleException
public Boolean getSynchronous()
public void setSynchronous(Boolean synchronous)
public boolean isDynamicRoutes()
OutboundRouter
isDynamicRoutes
in interface OutboundRouter
isDynamicRoutes
in class AbstractOutboundRouter
protected abstract List<Object> getRecipients(MuleEvent event) throws CouldNotRouteOutboundMessageException
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.