public class QuartzScheduledPollConsumerScheduler
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.spi.ScheduledPollConsumerScheduler, org.apache.camel.NonManagedService
ScheduledPollConsumerScheduler
which uses a
CronTrigger
to define when the poll should be triggered.Constructor and Description |
---|
QuartzScheduledPollConsumerScheduler() |
Modifier and Type | Method and Description |
---|---|
protected void |
doShutdown() |
protected void |
doStart() |
protected void |
doStop() |
org.apache.camel.CamelContext |
getCamelContext() |
String |
getCron() |
org.quartz.Scheduler |
getQuartzScheduler() |
TimeZone |
getTimeZone() |
String |
getTriggerGroup() |
String |
getTriggerId() |
boolean |
isSchedulerStarted() |
void |
onInit(org.apache.camel.Consumer consumer) |
void |
scheduleTask(Runnable runnable) |
void |
setCamelContext(org.apache.camel.CamelContext camelContext) |
void |
setCron(String cron) |
void |
setQuartzScheduler(org.quartz.Scheduler scheduler) |
void |
setTimeZone(TimeZone timeZone) |
void |
setTriggerGroup(String triggerGroup) |
void |
setTriggerId(String triggerId) |
void |
startScheduler() |
void |
unscheduleTask() |
doResume, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public QuartzScheduledPollConsumerScheduler()
public void onInit(org.apache.camel.Consumer consumer)
onInit
in interface org.apache.camel.spi.ScheduledPollConsumerScheduler
public void scheduleTask(Runnable runnable)
scheduleTask
in interface org.apache.camel.spi.ScheduledPollConsumerScheduler
public void unscheduleTask()
unscheduleTask
in interface org.apache.camel.spi.ScheduledPollConsumerScheduler
public void startScheduler()
startScheduler
in interface org.apache.camel.spi.ScheduledPollConsumerScheduler
public boolean isSchedulerStarted()
isSchedulerStarted
in interface org.apache.camel.spi.ScheduledPollConsumerScheduler
public void setCamelContext(org.apache.camel.CamelContext camelContext)
setCamelContext
in interface org.apache.camel.CamelContextAware
public org.apache.camel.CamelContext getCamelContext()
getCamelContext
in interface org.apache.camel.CamelContextAware
public org.quartz.Scheduler getQuartzScheduler()
public void setQuartzScheduler(org.quartz.Scheduler scheduler)
public String getCron()
public void setCron(String cron)
public TimeZone getTimeZone()
public void setTimeZone(TimeZone timeZone)
public String getTriggerId()
public void setTriggerId(String triggerId)
public String getTriggerGroup()
public void setTriggerGroup(String triggerGroup)
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.support.ServiceSupport
Exception
Apache Camel