org.apache.camel.routepolicy.quartz

Class ScheduledRoutePolicy

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.RoutePolicySupport

org.apache.camel.routepolicy.quartz.ScheduledRoutePolicy

All Implemented Interfaces:

ScheduledRoutePolicyConstants, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.RoutePolicy, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

Direct Known Subclasses:

CronScheduledRoutePolicy, SimpleScheduledRoutePolicy

public abstract class ScheduledRoutePolicy
extends org.apache.camel.impl.RoutePolicySupport
implements ScheduledRoutePolicyConstants

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.camel.routepolicy.quartz.ScheduledRoutePolicyConstants

ScheduledRoutePolicyConstants.Action

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,ScheduledRouteDetails>	scheduledRouteDetailsMap

Fields inherited from class org.apache.camel.impl.RoutePolicySupport

log

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Fields inherited from interface org.apache.camel.routepolicy.quartz.ScheduledRoutePolicyConstants

JOB_GROUP, JOB_RESUME, JOB_START, JOB_STOP, JOB_SUSPEND, SCHEDULED_ACTION, SCHEDULED_ROUTE, SCHEDULED_TRIGGER, TRIGGER_GROUP, TRIGGER_RESUME, TRIGGER_START, TRIGGER_STOP, TRIGGER_SUSPEND

Constructor Summary

Constructors

Constructor and Description
ScheduledRoutePolicy()

Method Summary

Methods

Modifier and Type	Method and Description
protected org.quartz.JobDetail	createJobDetail(ScheduledRoutePolicyConstants.Action action, org.apache.camel.Route route)
protected abstract org.quartz.Trigger	createTrigger(ScheduledRoutePolicyConstants.Action action, org.apache.camel.Route route)
void	deleteRouteJob(ScheduledRoutePolicyConstants.Action action, ScheduledRouteDetails scheduledRouteDetails)
protected void	doStop()
int	getRouteStopGracePeriod()
protected ScheduledRouteDetails	getScheduledRouteDetails(String routeId)
org.quartz.Scheduler	getScheduler()
TimeUnit	getTimeUnit()
protected void	loadCallbackDataIntoSchedulerContext(org.quartz.JobDetail jobDetail, ScheduledRoutePolicyConstants.Action action, org.apache.camel.Route route)
protected void	onJobExecute(ScheduledRoutePolicyConstants.Action action, org.apache.camel.Route route)
void	pauseRouteTrigger(ScheduledRoutePolicyConstants.Action action, String routeId)
protected void	registerRouteToScheduledRouteDetails(org.apache.camel.Route route)
void	resumeRouteTrigger(ScheduledRoutePolicyConstants.Action action, String routeId)
String	retrieveJobDetailGroup(ScheduledRoutePolicyConstants.Action action, ScheduledRouteDetails scheduledRouteDetails)
String	retrieveJobDetailName(ScheduledRoutePolicyConstants.Action action, ScheduledRouteDetails scheduledRouteDetails)
String	retrieveTriggerGroup(ScheduledRoutePolicyConstants.Action action, String routeId)
String	retrieveTriggerName(ScheduledRoutePolicyConstants.Action action, String routeId)
void	scheduleRoute(ScheduledRoutePolicyConstants.Action action, org.apache.camel.Route route)
void	setRouteStopGracePeriod(int routeStopGracePeriod)
void	setScheduler(org.quartz.Scheduler scheduler)
void	setTimeUnit(TimeUnit timeUnit)
protected void	updateScheduledRouteDetails(ScheduledRoutePolicyConstants.Action action, org.quartz.JobDetail jobDetail, org.quartz.Trigger trigger, org.apache.camel.Route route)

Methods inherited from class org.apache.camel.impl.RoutePolicySupport

doStart, getExceptionHandler, handleException, onExchangeBegin, onExchangeDone, onInit, onRemove, onResume, onStart, onStop, onSuspend, resumeRoute, setExceptionHandler, startConsumer, startRoute, stopConsumer, stopRoute, stopRoute, suspendRoute, suspendRoute

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

scheduledRouteDetailsMap

protected Map<String,ScheduledRouteDetails> scheduledRouteDetailsMap

Constructor Detail

ScheduledRoutePolicy

public ScheduledRoutePolicy()

Method Detail

createTrigger

protected abstract org.quartz.Trigger createTrigger(ScheduledRoutePolicyConstants.Action action,
                               org.apache.camel.Route route)
                                             throws Exception

Throws:

Exception

onJobExecute

protected void onJobExecute(ScheduledRoutePolicyConstants.Action action,
                org.apache.camel.Route route)
                     throws Exception

Throws:

Exception

scheduleRoute

public void scheduleRoute(ScheduledRoutePolicyConstants.Action action,
                 org.apache.camel.Route route)
                   throws Exception

Throws:

Exception

pauseRouteTrigger

public void pauseRouteTrigger(ScheduledRoutePolicyConstants.Action action,
                     String routeId)
                       throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

resumeRouteTrigger

public void resumeRouteTrigger(ScheduledRoutePolicyConstants.Action action,
                      String routeId)
                        throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class org.apache.camel.impl.RoutePolicySupport

Throws:

Exception

deleteRouteJob

public void deleteRouteJob(ScheduledRoutePolicyConstants.Action action,
                  ScheduledRouteDetails scheduledRouteDetails)
                    throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

createJobDetail

protected org.quartz.JobDetail createJobDetail(ScheduledRoutePolicyConstants.Action action,
                                   org.apache.camel.Route route)
                                        throws Exception

Throws:

Exception

updateScheduledRouteDetails

protected void updateScheduledRouteDetails(ScheduledRoutePolicyConstants.Action action,
                               org.quartz.JobDetail jobDetail,
                               org.quartz.Trigger trigger,
                               org.apache.camel.Route route)
                                    throws Exception

Throws:

Exception

loadCallbackDataIntoSchedulerContext

protected void loadCallbackDataIntoSchedulerContext(org.quartz.JobDetail jobDetail,
                                        ScheduledRoutePolicyConstants.Action action,
                                        org.apache.camel.Route route)
                                             throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

retrieveTriggerName

public String retrieveTriggerName(ScheduledRoutePolicyConstants.Action action,
                         String routeId)

retrieveTriggerGroup

public String retrieveTriggerGroup(ScheduledRoutePolicyConstants.Action action,
                          String routeId)

retrieveJobDetailName

public String retrieveJobDetailName(ScheduledRoutePolicyConstants.Action action,
                           ScheduledRouteDetails scheduledRouteDetails)

retrieveJobDetailGroup

public String retrieveJobDetailGroup(ScheduledRoutePolicyConstants.Action action,
                            ScheduledRouteDetails scheduledRouteDetails)

registerRouteToScheduledRouteDetails

protected void registerRouteToScheduledRouteDetails(org.apache.camel.Route route)

getScheduledRouteDetails

protected ScheduledRouteDetails getScheduledRouteDetails(String routeId)

setScheduler

public void setScheduler(org.quartz.Scheduler scheduler)

getScheduler

public org.quartz.Scheduler getScheduler()

setRouteStopGracePeriod

public void setRouteStopGracePeriod(int routeStopGracePeriod)

getRouteStopGracePeriod

public int getRouteStopGracePeriod()

setTimeUnit

public void setTimeUnit(TimeUnit timeUnit)

getTimeUnit

public TimeUnit getTimeUnit()