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, ShutdownableService

public class OnCompletionProcessor
extends ServiceSupport
implements Processor, Traceable

Version:
$Revision: 19603 $

Constructor Summary
OnCompletionProcessor(CamelContext camelContext, Processor processor, ExecutorService executorService, boolean onCompleteOnly, boolean onFailureOnly, Predicate onWhen, boolean useOriginalBody)
           
 
Method Summary
protected static void doProcess(Processor processor, Exchange exchange)
          Processes the exchange by the processors
protected  void doStart()
           
protected  void doStop()
           
 CamelContext getCamelContext()
           
 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
 String toString()
           
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, doShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, removeChildService, shutdown, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

OnCompletionProcessor

public OnCompletionProcessor(CamelContext camelContext,
                             Processor processor,
                             ExecutorService executorService,
                             boolean onCompleteOnly,
                             boolean onFailureOnly,
                             Predicate onWhen,
                             boolean useOriginalBody)
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

getCamelContext

public CamelContext getCamelContext()

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.

doProcess

protected static void doProcess(Processor processor,
                                Exchange exchange)
Processes the exchange by the processors

Parameters:
processor - the processor
exchange - the exchange

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

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 label should be short and precise.

Specified by:
getTraceLabel in interface Traceable
Returns:
the label


Copyright © 2007-2010 IONA Open Source Community. All Rights Reserved.