@UriEndpoint(firstVersion="1.0.0", scheme="quartz", title="Quartz", syntax="quartz:groupName/timerName", consumerOnly=true, consumerClass=QuartzConsumer.class, label="scheduling") public class QuartzEndpoint extends org.apache.camel.impl.DefaultEndpoint implements org.apache.camel.ShutdownableService
Constructor and Description |
---|
QuartzEndpoint(String endpointUri,
QuartzComponent component) |
Modifier and Type | Method and Description |
---|---|
void |
addTrigger(org.quartz.Trigger trigger,
org.quartz.JobDetail detail) |
void |
consumerStarted(QuartzConsumer consumer) |
void |
consumerStopped(QuartzConsumer consumer) |
QuartzConsumer |
createConsumer(org.apache.camel.Processor processor) |
protected String |
createEndpointUri() |
org.apache.camel.Exchange |
createExchange(org.quartz.JobExecutionContext jobExecutionContext) |
protected org.apache.camel.processor.loadbalancer.LoadBalancer |
createLoadBalancer() |
org.apache.camel.Producer |
createProducer() |
void |
deleteTrigger(org.quartz.Trigger trigger) |
protected void |
doShutdown() |
protected void |
doStart() |
protected void |
doStop() |
QuartzComponent |
getComponent() |
String |
getCron() |
String |
getGroupName() |
org.quartz.JobDetail |
getJobDetail() |
protected String |
getJobName() |
Map<String,Object> |
getJobParameters() |
org.apache.camel.processor.loadbalancer.LoadBalancer |
getLoadBalancer() |
int |
getStartDelayedSeconds() |
String |
getTimerName() |
org.quartz.Trigger |
getTrigger() |
Map<String,Object> |
getTriggerParameters() |
boolean |
isDeleteJob() |
boolean |
isFireNow() |
boolean |
isPauseJob() |
boolean |
isSingleton() |
boolean |
isStateful() |
boolean |
isUsingFixedCamelContextName() |
void |
onJobExecute(org.quartz.JobExecutionContext jobExecutionContext)
This method is invoked when a Quartz job is fired.
|
void |
pauseTrigger(org.quartz.Trigger trigger) |
void |
setCron(String cron)
Specifies a cron expression to define when to trigger.
|
void |
setDeleteJob(boolean deleteJob)
If set to true, then the trigger automatically delete when route stop.
|
void |
setFireNow(boolean fireNow)
Whether to fire the scheduler asap when its started using the simple trigger (this option does not support cron)
|
void |
setGroupName(String groupName)
The quartz group name to use.
|
void |
setJobDetail(org.quartz.JobDetail jobDetail) |
void |
setJobParameters(Map<String,Object> jobParameters)
To configure additional options on the job.
|
void |
setLoadBalancer(org.apache.camel.processor.loadbalancer.LoadBalancer loadBalancer) |
void |
setPauseJob(boolean pauseJob)
If set to true, then the trigger automatically pauses when route stop.
|
void |
setStartDelayedSeconds(int startDelayedSeconds)
Seconds to wait before starting the quartz scheduler.
|
void |
setStateful(boolean stateful)
Uses a Quartz StatefulJob instead of the default job.
|
void |
setTimerName(String timerName)
The quartz timer name to use.
|
void |
setTrigger(org.quartz.Trigger trigger) |
void |
setTriggerParameters(Map<String,Object> triggerParameters)
To configure additional options on the trigger.
|
void |
setUsingFixedCamelContextName(boolean usingFixedCamelContextName)
If it is true, JobDataMap uses the CamelContext name directly to reference the CamelContext,
if it is false, JobDataMap uses use the CamelContext management name which could be changed during the deploy time.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public QuartzEndpoint(String endpointUri, QuartzComponent component)
public void addTrigger(org.quartz.Trigger trigger, org.quartz.JobDetail detail) throws org.quartz.SchedulerException
org.quartz.SchedulerException
public void pauseTrigger(org.quartz.Trigger trigger) throws org.quartz.SchedulerException
org.quartz.SchedulerException
public void deleteTrigger(org.quartz.Trigger trigger) throws org.quartz.SchedulerException
org.quartz.SchedulerException
public void onJobExecute(org.quartz.JobExecutionContext jobExecutionContext) throws org.quartz.JobExecutionException
jobExecutionContext
- the Quartz Job contextorg.quartz.JobExecutionException
public org.apache.camel.Exchange createExchange(org.quartz.JobExecutionContext jobExecutionContext)
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public QuartzConsumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
protected String createEndpointUri()
createEndpointUri
in class org.apache.camel.impl.DefaultEndpoint
protected String getJobName()
public QuartzComponent getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public org.apache.camel.processor.loadbalancer.LoadBalancer getLoadBalancer()
public String getGroupName()
public void setGroupName(String groupName)
public String getTimerName()
public void setTimerName(String timerName)
public String getCron()
public void setCron(String cron)
public void setLoadBalancer(org.apache.camel.processor.loadbalancer.LoadBalancer loadBalancer)
public org.quartz.JobDetail getJobDetail()
public void setJobDetail(org.quartz.JobDetail jobDetail)
public org.quartz.Trigger getTrigger()
public void setTrigger(org.quartz.Trigger trigger)
public boolean isStateful()
public void setStateful(boolean stateful)
public boolean isDeleteJob()
public void setDeleteJob(boolean deleteJob)
public boolean isPauseJob()
public void setPauseJob(boolean pauseJob)
public boolean isFireNow()
public void setFireNow(boolean fireNow)
public int getStartDelayedSeconds()
public void setStartDelayedSeconds(int startDelayedSeconds)
public boolean isUsingFixedCamelContextName()
public void setUsingFixedCamelContextName(boolean usingFixedCamelContextName)
public void setTriggerParameters(Map<String,Object> triggerParameters)
public void setJobParameters(Map<String,Object> jobParameters)
public void consumerStarted(QuartzConsumer consumer) throws org.quartz.SchedulerException
org.quartz.SchedulerException
public void consumerStopped(QuartzConsumer consumer) throws org.quartz.SchedulerException
org.quartz.SchedulerException
protected org.apache.camel.processor.loadbalancer.LoadBalancer createLoadBalancer()
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultEndpoint
Exception
Apache Camel