org.mule.routing
Class WireTap
java.lang.Object
org.mule.processor.AbstractMuleObjectOwner<MessageProcessor>
org.mule.processor.AbstractMessageProcessorOwner
org.mule.routing.WireTap
- All Implemented Interfaces:
- AnnotatedObject, FlowConstructAware, MuleContextAware, Disposable, Initialisable, Lifecycle, Startable, Stoppable, MessageProcessor
public class WireTap
- extends AbstractMessageProcessorOwner
- implements MessageProcessor
The WireTap
MessageProcessor allows inspection of messages in a flow.
The incoming message is is sent to both the primary and wiretap outputs. The flow
of the primary output will be unmodified and a copy of the message used for the
wiretap output.
An optional filter can be used to filter which message are sent to the wiretap
output, this filter does not affect the flow to the primary output. If there is an
error sending to the wiretap output no exception will be thrown but rather an
error logged.
EIP Reference: http://www.eaipatterns.com/WireTap.html
Methods inherited from interface org.mule.api.lifecycle.Startable |
start |
Methods inherited from interface org.mule.api.lifecycle.Stoppable |
stop |
logger
protected final transient Log logger
tap
protected volatile MessageProcessor tap
filter
protected volatile Filter filter
filteredTap
protected MessageProcessor filteredTap
WireTap
public WireTap()
process
public MuleEvent process(MuleEvent event)
throws MuleException
- Description copied from interface:
MessageProcessor
- Invokes the MessageProcessor.
- Specified by:
process
in interface MessageProcessor
- Parameters:
event
- MuleEvent to be processed
- Returns:
- optional response MuleEvent
- Throws:
MuleException
getTap
public MessageProcessor getTap()
setTap
public void setTap(MessageProcessor tap)
setMessageProcessor
@Deprecated
public void setMessageProcessor(MessageProcessor tap)
- Deprecated.
getFilter
public Filter getFilter()
setFilter
public void setFilter(Filter filter)
toString
public String toString()
- Overrides:
toString
in class Object
getOwnedMessageProcessors
protected List<MessageProcessor> getOwnedMessageProcessors()
- Specified by:
getOwnedMessageProcessors
in class AbstractMessageProcessorOwner
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.