org.apache.camel.pollconsumer.quartz2
Class QuartzScheduledPollConsumerScheduler

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.pollconsumer.quartz2.QuartzScheduledPollConsumerScheduler
All Implemented Interfaces:
org.apache.camel.CamelContextAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.ScheduledPollConsumerScheduler, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class QuartzScheduledPollConsumerScheduler
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.spi.ScheduledPollConsumerScheduler

A quartz based ScheduledPollConsumerScheduler which uses a CronTrigger to define when the poll should be triggered.


Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
QuartzScheduledPollConsumerScheduler()
           
 
Method Summary
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()
           
 
Methods inherited from class org.apache.camel.support.ServiceSupport
doResume, 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
 
Methods inherited from interface org.apache.camel.ShutdownableService
shutdown
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

QuartzScheduledPollConsumerScheduler

public QuartzScheduledPollConsumerScheduler()
Method Detail

onInit

public void onInit(org.apache.camel.Consumer consumer)
Specified by:
onInit in interface org.apache.camel.spi.ScheduledPollConsumerScheduler

scheduleTask

public void scheduleTask(Runnable runnable)
Specified by:
scheduleTask in interface org.apache.camel.spi.ScheduledPollConsumerScheduler

unscheduleTask

public void unscheduleTask()
Specified by:
unscheduleTask in interface org.apache.camel.spi.ScheduledPollConsumerScheduler

startScheduler

public void startScheduler()
Specified by:
startScheduler in interface org.apache.camel.spi.ScheduledPollConsumerScheduler

isSchedulerStarted

public boolean isSchedulerStarted()
Specified by:
isSchedulerStarted in interface org.apache.camel.spi.ScheduledPollConsumerScheduler

setCamelContext

public void setCamelContext(org.apache.camel.CamelContext camelContext)
Specified by:
setCamelContext in interface org.apache.camel.CamelContextAware

getCamelContext

public org.apache.camel.CamelContext getCamelContext()
Specified by:
getCamelContext in interface org.apache.camel.CamelContextAware

getQuartzScheduler

public org.quartz.Scheduler getQuartzScheduler()

setQuartzScheduler

public void setQuartzScheduler(org.quartz.Scheduler scheduler)

getCron

public String getCron()

setCron

public void setCron(String cron)

getTimeZone

public TimeZone getTimeZone()

setTimeZone

public void setTimeZone(TimeZone timeZone)

getTriggerId

public String getTriggerId()

setTriggerId

public void setTriggerId(String triggerId)

getTriggerGroup

public String getTriggerGroup()

setTriggerGroup

public void setTriggerGroup(String triggerGroup)

doStart

protected void doStart()
                throws Exception
Specified by:
doStart in class org.apache.camel.support.ServiceSupport
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Specified by:
doStop in class org.apache.camel.support.ServiceSupport
Throws:
Exception

doShutdown

protected void doShutdown()
                   throws Exception
Overrides:
doShutdown in class org.apache.camel.support.ServiceSupport
Throws:
Exception


Apache Camel