public class ChainingRouter extends FilteringOutboundRouter
ChainingRouter
is used to pass a Mule event through multiple
endpoints using the result of the first as the input for the second.ENABLE_CORRELATION_ALWAYS, ENABLE_CORRELATION_IF_NOT_SET, ENABLE_CORRELATION_NEVER, enableCorrelation, endpoints, logger, messageInfoMapping, replyTo, transactionConfig
muleContext
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
ChainingRouter() |
Modifier and Type | Method and Description |
---|---|
protected void |
processIntermediaryResult(MuleMessage localResult,
MuleMessage intermediaryResult)
Process intermediary result of invocation.
|
MuleMessage |
route(MuleMessage message,
MuleSession session,
boolean synchronous)
This method is responsible for routing the Message via the MuleSession.
|
addEndpoint, getEndpoint, getFilter, getTransformers, isMatch, isUseTemplates, setFilter, setTransformers, setUseTemplates
createTransactionTemplate, dispatch, getEnableCorrelation, getEndpoint, getEndpoints, getMessageInfoMapping, getReplyTo, getTransactionConfig, isDynamicEndpoints, 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 void processIntermediaryResult(MuleMessage localResult, MuleMessage intermediaryResult)
super(localResult, intermediaryResult)
,
unless they are modifying the correlation workflow (if you know what that means,
you know what you are doing and when to do it).
Default implementation propagates
the following properties:
localResult
- result of the last endpoint invocationintermediaryResult
- the message travelling across the endpointsCopyright © 2003–2013 MuleSource, Inc.. All rights reserved.