org.apache.camel.processor.interceptor
Class DelayInterceptor

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.processor.DelegateAsyncProcessor
          extended by org.apache.camel.processor.DelayProcessorSupport
              extended by org.apache.camel.processor.interceptor.DelayInterceptor
All Implemented Interfaces:
AsyncProcessor, Navigate<Processor>, Processor, Service, ShutdownableService

public class DelayInterceptor
extends DelayProcessorSupport

An interceptor for delaying routes.


Field Summary
 
Fields inherited from class org.apache.camel.processor.DelayProcessorSupport
log
 
Fields inherited from class org.apache.camel.processor.DelegateAsyncProcessor
processor
 
Constructor Summary
DelayInterceptor(ProcessorDefinition<?> node, Processor target, Delayer delayer)
           
 
Method Summary
 long calculateDelay(Exchange exchange)
           
 String toString()
           
 
Methods inherited from class org.apache.camel.processor.DelayProcessorSupport
currentSystemTime, delay, doStart, handleSleepInterruptedException, isAsyncDelayed, isCallerRunsWhenRejected, process, setAsyncDelayed, setCallerRunsWhenRejected
 
Methods inherited from class org.apache.camel.processor.DelegateAsyncProcessor
doStop, getProcessor, hasNext, next, process, processNext, setProcessor, setProcessor
 
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

DelayInterceptor

public DelayInterceptor(ProcessorDefinition<?> node,
                        Processor target,
                        Delayer delayer)
Method Detail

toString

public String toString()
Overrides:
toString in class DelegateAsyncProcessor

calculateDelay

public long calculateDelay(Exchange exchange)
Specified by:
calculateDelay in class DelayProcessorSupport


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