public class SxcFilteringOutboundRouter extends FilteringOutboundRouter
FilteringRouter
is a router that accepts events based on a filter
set.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 |
---|
SxcFilteringOutboundRouter() |
Modifier and Type | Method and Description |
---|---|
protected void |
addEventHandlers(com.envoisolutions.sxc.xpath.XPathBuilder xpathBuilder,
Filter filter) |
static MuleMessage |
getCurrentMessage() |
Map<String,String> |
getNamespaces() |
protected ReversibleXMLStreamReader |
getXMLStreamReader(MuleMessage message)
Gets an XMLStreamReader for this message.
|
void |
initialise()
Method used to perform any initialisation work.
|
boolean |
isMatch(MuleMessage message)
Determines if the event should be processed
|
void |
setFilter(Filter filter) |
void |
setMuleContext(MuleContext context) |
void |
setNamespaces(Map<String,String> namespaces) |
boolean |
testMatch(MuleMessage message) |
addRoute, getFilter, getRoute, getTransformers, isTransformBeforeMatch, isUseTemplates, route, setTransformers, setUseTemplates
cloneMessage, cloneMessage, createEventToRoute, dispose, getEnableCorrelation, getMuleContext, getOwnedMessageProcessors, getReplyTo, getResultsHandler, getRoute, getRouterStatistics, getRoutes, getTransactionConfig, isDynamicRoutes, 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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setFlowConstruct
public void setMuleContext(MuleContext context)
setMuleContext
in interface MuleContextAware
setMuleContext
in class AbstractMuleObjectOwner<MessageProcessor>
public void setFilter(Filter filter)
setFilter
in class FilteringOutboundRouter
protected void addEventHandlers(com.envoisolutions.sxc.xpath.XPathBuilder xpathBuilder, Filter filter)
public void initialise() throws InitialisationException
Initialisable
InitialisationException
should be thrown,
causing the Mule instance to shutdown. If the error is recoverable, say by
retrying to connect, a RecoverableException
should be thrown.
There is no guarantee that by throwing a Recoverable exception that the Mule
instance will not shut down.initialise
in interface Initialisable
initialise
in class FilteringOutboundRouter
InitialisationException
- if a fatal error occurs causing the Mule instance to shutdownRecoverableException
- if an error occurs that can be recovered frompublic boolean isMatch(MuleMessage message) throws MuleException
Matchable
isMatch
in interface Matchable
isMatch
in class FilteringOutboundRouter
message
- the current message to evaluateMuleException
- if the event cannot be evaluatedpublic boolean testMatch(MuleMessage message) throws MuleException
MuleException
protected ReversibleXMLStreamReader getXMLStreamReader(MuleMessage message) throws TransformerException
message
- TransformerException
public static MuleMessage getCurrentMessage()
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.