public class RoundRobinXmlSplitter extends FilteringXmlMessageSplitter
Modifier and Type | Field and Description |
---|---|
protected boolean |
enableEndpointFiltering |
externalSchemaLocation, namespaces, nodesContext, propertiesContext, splitExpression, validateSchema
honorSynchronicity, multimatch
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 |
---|
RoundRobinXmlSplitter() |
Modifier and Type | Method and Description |
---|---|
void |
addEndpoint(OutboundEndpoint endpoint)
Adds an endpoint to this router
|
protected OutboundEndpoint |
getEndpointForMessage(MuleMessage message)
Retrieves a specific message part for the given endpoint.
|
boolean |
isDeterministic() |
boolean |
isEnableEndpointFiltering() |
MuleMessage |
route(MuleMessage message,
MuleSession session,
boolean synchronous)
This method is responsible for routing the Message via the MuleSession.
|
void |
setDeterministic(boolean deterministic) |
void |
setEnableEndpointFiltering(boolean enableEndpointFiltering) |
cleanup, getExternalSchemaLocation, getMessagePart, getNamespaces, getSplitExpression, initialise, isValidateSchema, setExternalSchemaLocation, setNamespaces, setSplitExpression, setValidateSchema
isHonorSynchronicity, setHonorSynchronicity
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 AbstractMessageSplitter
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 getEndpointForMessage(MuleMessage message)
message
- the current message being processedpublic void addEndpoint(OutboundEndpoint endpoint)
OutboundRouter
addEndpoint
in interface OutboundRouter
addEndpoint
in class FilteringOutboundRouter
endpoint
- the endpoint to add to the routerpublic boolean isEnableEndpointFiltering()
public void setEnableEndpointFiltering(boolean enableEndpointFiltering)
public boolean isDeterministic()
public void setDeterministic(boolean deterministic)
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.