org.apache.camel.processor
Class SendProcessor
java.lang.Object
org.apache.camel.impl.ServiceSupport
org.apache.camel.processor.SendProcessor
- All Implemented Interfaces:
- Processor, Service
- Direct Known Subclasses:
- WireTapProcessor
public class SendProcessor
- extends ServiceSupport
- implements Processor
Processor for forwarding 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 |
LOG
protected static final transient org.apache.commons.logging.Log LOG
producerCache
protected ProducerCache producerCache
destination
protected Endpoint destination
pattern
protected ExchangePattern pattern
SendProcessor
public SendProcessor(Endpoint destination)
SendProcessor
public SendProcessor(Endpoint destination,
ExchangePattern pattern)
toString
public String toString()
- Overrides:
toString
in class Object
process
public void process(Exchange exchange)
throws Exception
- Description copied from interface:
Processor
- Processes the message exchange
- Specified by:
process
in interface Processor
- Parameters:
exchange
- the message exchange
- Throws:
Exception
- if an internal processing error has occurred.
getProducerCache
protected ProducerCache getProducerCache(Exchange exchange)
throws Exception
- Throws:
Exception
getDestination
public Endpoint getDestination()
configureExchange
protected Exchange configureExchange(Exchange exchange,
ExchangePattern pattern)
doStart
protected void doStart()
throws Exception
- Specified by:
doStart
in class ServiceSupport
- Throws:
Exception
doStop
protected void doStop()
throws Exception
- Specified by:
doStop
in class ServiceSupport
- Throws:
Exception
Copyright © 2009 Apache Software Foundation. All Rights Reserved.