public abstract class ScheduledRoutePolicy extends org.apache.camel.support.RoutePolicySupport implements ScheduledRoutePolicyConstants, org.apache.camel.NonManagedService
ScheduledRoutePolicyConstants.Action
Modifier and Type | Field and Description |
---|---|
protected Map<String,ScheduledRouteDetails> |
scheduledRouteDetailsMap |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
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 and Description |
---|
ScheduledRoutePolicy() |
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 |
onRemove(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) |
org.quartz.JobKey |
retrieveJobKey(ScheduledRoutePolicyConstants.Action action,
ScheduledRouteDetails scheduledRouteDetails) |
org.quartz.TriggerKey |
retrieveTriggerKey(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) |
doStart, getExceptionHandler, handleException, onExchangeBegin, onExchangeDone, onInit, onResume, onStart, onStop, onSuspend, resumeRoute, setExceptionHandler, startConsumer, startRoute, stopConsumer, stopRoute, stopRoute, suspendRoute, suspendRoute
protected Map<String,ScheduledRouteDetails> scheduledRouteDetailsMap
protected abstract org.quartz.Trigger createTrigger(ScheduledRoutePolicyConstants.Action action, org.apache.camel.Route route) throws Exception
Exception
protected void onJobExecute(ScheduledRoutePolicyConstants.Action action, org.apache.camel.Route route) throws Exception
Exception
public void onRemove(org.apache.camel.Route route)
onRemove
in interface org.apache.camel.spi.RoutePolicy
onRemove
in class org.apache.camel.support.RoutePolicySupport
public void scheduleRoute(ScheduledRoutePolicyConstants.Action action, org.apache.camel.Route route) throws Exception
Exception
public void pauseRouteTrigger(ScheduledRoutePolicyConstants.Action action, String routeId) throws org.quartz.SchedulerException
org.quartz.SchedulerException
public void resumeRouteTrigger(ScheduledRoutePolicyConstants.Action action, String routeId) throws org.quartz.SchedulerException
org.quartz.SchedulerException
protected void doStop() throws Exception
doStop
in class org.apache.camel.support.RoutePolicySupport
Exception
public void deleteRouteJob(ScheduledRoutePolicyConstants.Action action, ScheduledRouteDetails scheduledRouteDetails) throws org.quartz.SchedulerException
org.quartz.SchedulerException
protected org.quartz.JobDetail createJobDetail(ScheduledRoutePolicyConstants.Action action, org.apache.camel.Route route) throws Exception
Exception
protected void updateScheduledRouteDetails(ScheduledRoutePolicyConstants.Action action, org.quartz.JobDetail jobDetail, org.quartz.Trigger trigger, org.apache.camel.Route route) throws Exception
Exception
protected void loadCallbackDataIntoSchedulerContext(org.quartz.JobDetail jobDetail, ScheduledRoutePolicyConstants.Action action, org.apache.camel.Route route) throws org.quartz.SchedulerException
org.quartz.SchedulerException
public org.quartz.TriggerKey retrieveTriggerKey(ScheduledRoutePolicyConstants.Action action, String routeId)
public org.quartz.JobKey retrieveJobKey(ScheduledRoutePolicyConstants.Action action, ScheduledRouteDetails scheduledRouteDetails)
protected void registerRouteToScheduledRouteDetails(org.apache.camel.Route route)
protected ScheduledRouteDetails getScheduledRouteDetails(String routeId)
public void setScheduler(org.quartz.Scheduler scheduler)
public org.quartz.Scheduler getScheduler()
public void setRouteStopGracePeriod(int routeStopGracePeriod)
public int getRouteStopGracePeriod()
public void setTimeUnit(TimeUnit timeUnit)
public TimeUnit getTimeUnit()
Apache Camel