org.mule.routing.outbound
Class AbstractRecipientList
java.lang.Object
org.mule.processor.AbstractMuleObjectOwner<MessageProcessor>
org.mule.processor.AbstractMessageProcessorOwner
org.mule.routing.outbound.AbstractOutboundRouter
org.mule.routing.outbound.FilteringOutboundRouter
org.mule.routing.outbound.AbstractRecipientList
- All Implemented Interfaces:
- AnnotatedObject, FlowConstructAware, MuleContextAware, Disposable, Initialisable, Lifecycle, Startable, Stoppable, MessageProcessor, MessageRouter, Matchable, MatchableMessageProcessor, MatchableMessageRouter, OutboundRouter, RouterStatisticsRecorder, TransformingMatchable
- Direct Known Subclasses:
- ExpressionRecipientList, StaticRecipientList
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.
Methods inherited from class org.mule.routing.outbound.FilteringOutboundRouter |
addRoute, getFilter, getRoute, getTransformers, initialise, isMatch, isTransformBeforeMatch, isUseTemplates, setFilter, setTransformers, setUseTemplates |
Methods inherited from class org.mule.routing.outbound.AbstractOutboundRouter |
cloneMessage, createEventToRoute, dispose, 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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AbstractRecipientList
public AbstractRecipientList()
route
public MuleEvent route(MuleEvent event)
throws RoutingException
- Overrides:
route
in class FilteringOutboundRouter
- Throws:
RoutingException
getRecipientEndpoint
protected OutboundEndpoint getRecipientEndpoint(MuleMessage message,
Object recipient)
throws MuleException
- Throws:
MuleException
getRecipientEndpointFromUri
protected OutboundEndpoint getRecipientEndpointFromUri(EndpointURI uri)
throws MuleException
- Throws:
MuleException
getRecipientEndpointFromString
protected OutboundEndpoint getRecipientEndpointFromString(MuleMessage message,
String recipient)
throws MuleException
- Throws:
MuleException
buildOutboundEndpoint
protected OutboundEndpoint buildOutboundEndpoint(String recipient)
throws MuleException
- Throws:
MuleException
getSynchronous
public Boolean getSynchronous()
setSynchronous
public void setSynchronous(Boolean synchronous)
isDynamicRoutes
public boolean isDynamicRoutes()
- Description copied from interface:
OutboundRouter
- Determines whether this router supports dynamic route. i.e. routes that are
not configured at design time. routes might be pulled from the message or
payload.
- Specified by:
isDynamicRoutes
in interface OutboundRouter
- Overrides:
isDynamicRoutes
in class AbstractOutboundRouter
getRecipients
protected abstract List<Object> getRecipients(MuleEvent event)
throws CouldNotRouteOutboundMessageException
- Throws:
CouldNotRouteOutboundMessageException
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.