org.apache.camel.bam.rules
Class TemporalRule

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.bam.rules.TemporalRule
All Implemented Interfaces:
Service, ShutdownableService

public class TemporalRule
extends ServiceSupport

A temporal rule for use within BAM

Version:

Constructor Summary
TemporalRule(TimeExpression first, TimeExpression second)
           
 
Method Summary
protected  Date add(Date date, long millis)
          Returns the date in the future adding the given number of millis
protected  Exchange createExchange()
           
protected  void doStart()
           
protected  void doStop()
           
 OutputDefinition errorIfOver(long millis)
           
 OutputDefinition errorIfOver(Time builder)
           
 TemporalRule expectWithin(long millis)
           
 TemporalRule expectWithin(Time builder)
           
 TimeExpression getFirst()
           
 Processor getOverdueAction()
           
 TimeExpression getSecond()
           
 void processExchange(Exchange exchange, ProcessInstance instance)
           
 void processExpired(ActivityState activityState)
           
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, removeChildService, resume, shutdown, start, start, stop, suspend
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TemporalRule

public TemporalRule(TimeExpression first,
                    TimeExpression second)
Method Detail

expectWithin

public TemporalRule expectWithin(Time builder)

expectWithin

public TemporalRule expectWithin(long millis)

errorIfOver

public OutputDefinition errorIfOver(Time builder)

errorIfOver

public OutputDefinition errorIfOver(long millis)

getFirst

public TimeExpression getFirst()

getSecond

public TimeExpression getSecond()

getOverdueAction

public Processor getOverdueAction()
                           throws Exception
Throws:
Exception

processExchange

public void processExchange(Exchange exchange,
                            ProcessInstance instance)

processExpired

public void processExpired(ActivityState activityState)
                    throws Exception
Throws:
Exception

createExchange

protected Exchange createExchange()

add

protected Date add(Date date,
                   long millis)
Returns the date in the future adding the given number of millis

Returns:
the date in the future

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


Apache CAMEL