org.apache.camel.bam.rules
Class TemporalRule

java.lang.Object
  org.apache.camel.impl.ServiceSupport
      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