public class SelectiveConsumer extends AbstractRouter implements InboundRouter
SelectiveConsumer
is an inbound router used to filter out unwanted
events. The filtering is performed by a Filter
that can be set
on the router.InboundRouter
,
InboundRouterCollection
,
RouterCollection
Modifier and Type | Field and Description |
---|---|
protected org.apache.commons.logging.Log |
logger |
muleContext
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
SelectiveConsumer() |
Modifier and Type | Method and Description |
---|---|
Filter |
getFilter() |
MessageInfoMapping |
getMessageInfoMapping() |
boolean |
isMatch(MuleEvent event)
Determines if the event should be processed by this router.
|
boolean |
isTransformFirst() |
MuleEvent[] |
process(MuleEvent event)
A received MuleEvent is passed to this method for processing.
|
void |
setFilter(Filter filter) |
void |
setMessageInfoMapping(MessageInfoMapping messageInfoMapping) |
void |
setTransformFirst(boolean transformFirst) |
dispose, getMuleContext, getRouterStatistics, initialise, setMuleContext, setRouterStatistics
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getRouterStatistics, setRouterStatistics
initialise
dispose
public boolean isMatch(MuleEvent event) throws MessagingException
InboundRouter
isMatch
in interface InboundRouter
event
- the current event to evaluateMessagingException
- if the event cannot be evaluatedSelectiveConsumer
public MuleEvent[] process(MuleEvent event) throws MessagingException
InboundRouter
process
in interface InboundRouter
event
- the event received by the inbound endpoint before it is passed to
the serviceMessagingException
- if an error occurs during processing of the eventpublic Filter getFilter()
public void setFilter(Filter filter)
public boolean isTransformFirst()
public void setTransformFirst(boolean transformFirst)
public MessageInfoMapping getMessageInfoMapping()
public void setMessageInfoMapping(MessageInfoMapping messageInfoMapping)
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.