org.apache.camel.processor
Class WireTapProcessor
java.lang.Object
org.apache.camel.impl.ServiceSupport
org.apache.camel.processor.SendProcessor
org.apache.camel.processor.WireTapProcessor
- All Implemented Interfaces:
- Processor, Service
public class WireTapProcessor
- extends SendProcessor
Processor for wire tapping exchanges to an endpoint destination.
- Version:
- $Revision: 779038 $
Methods inherited from class org.apache.camel.impl.ServiceSupport |
addChildService, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, removeChildService, start, stop |
WireTapProcessor
public WireTapProcessor(Endpoint destination)
WireTapProcessor
public WireTapProcessor(Endpoint destination,
ExchangePattern pattern)
doStart
protected void doStart()
throws Exception
- Overrides:
doStart
in class SendProcessor
- Throws:
Exception
doStop
protected void doStop()
throws Exception
- Overrides:
doStop
in class SendProcessor
- Throws:
Exception
toString
public String toString()
- Overrides:
toString
in class SendProcessor
process
public void process(Exchange exchange)
throws Exception
- Description copied from interface:
Processor
- Processes the message exchange
- Specified by:
process
in interface Processor
- Overrides:
process
in class SendProcessor
- Parameters:
exchange
- the message exchange
- Throws:
Exception
- if an internal processing error has occurred.
procesWireTap
protected void procesWireTap(Producer producer,
Exchange exchange)
- Wiretaps the exchange.
- Parameters:
exchange
- the exchange to wire tap
configureExchange
protected Exchange configureExchange(Exchange exchange,
ExchangePattern pattern)
- Overrides:
configureExchange
in class SendProcessor
getExecutorService
public ExecutorService getExecutorService()
setExecutorService
public void setExecutorService(ExecutorService executorService)
getNewExchangeProcessor
public Processor getNewExchangeProcessor()
setNewExchangeProcessor
public void setNewExchangeProcessor(Processor newExchangeProcessor)
getNewExchangeExpression
public Expression getNewExchangeExpression()
setNewExchangeExpression
public void setNewExchangeExpression(Expression newExchangeExpression)
Copyright © 2009 Apache Software Foundation. All Rights Reserved.