org.apache.camel.processor
Class OnCompletionProcessor

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.processor.OnCompletionProcessor
All Implemented Interfaces:
Processor, Traceable, Service

public class OnCompletionProcessor
extends ServiceSupport
implements Processor, Traceable

Version:
$Revision: 792977 $

Constructor Summary
OnCompletionProcessor(Processor processor, boolean onCompleteOnly, boolean onFailureOnly, Predicate onWhen)
           
 
Method Summary
protected  void doStart()
           
protected  void doStop()
           
 ExecutorService getExecutorService()
           
 String getTraceLabel()
          Gets the trace label used for logging when tracing is enabled.
protected  Exchange prepareExchange(Exchange exchange)
          Prepares the Exchange to send as onCompletion.
 void process(Exchange exchange)
          Processes the message exchange
 void setExecutorService(ExecutorService executorService)
           
 String toString()
           
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, removeChildService, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

OnCompletionProcessor

public OnCompletionProcessor(Processor processor,
                             boolean onCompleteOnly,
                             boolean onFailureOnly,
                             Predicate onWhen)
Method Detail

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

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.

prepareExchange

protected Exchange prepareExchange(Exchange exchange)
Prepares the Exchange to send as onCompletion.

Parameters:
exchange - the current exchange
Returns:
the exchange to be routed in onComplete

getExecutorService

public ExecutorService getExecutorService()

setExecutorService

public void setExecutorService(ExecutorService executorService)

toString

public String toString()
Overrides:
toString in class Object

getTraceLabel

public String getTraceLabel()
Description copied from interface: Traceable
Gets the trace label used for logging when tracing is enabled.

The lable should be short and precise.

Specified by:
getTraceLabel in interface Traceable
Returns:
the label


Apache CAMEL