org.apache.camel.component.quartz2
Class QuartzEndpoint
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultEndpoint
org.apache.camel.component.quartz2.QuartzEndpoint
- All Implemented Interfaces:
- org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class QuartzEndpoint
- extends org.apache.camel.impl.DefaultEndpoint
This endpoint represent each job to be created in scheduler. When consumer is started or stopped, it will
call back into onConsumerStart(QuartzConsumer)
to add/resume or onConsumerStop(QuartzConsumer)
to pause the scheduler trigger.
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString |
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 interface org.apache.camel.Service |
start, stop |
QuartzEndpoint
public QuartzEndpoint(String uri,
QuartzComponent quartzComponent)
getCron
public String getCron()
isStateful
public boolean isStateful()
isFireNow
public boolean isFireNow()
getTriggerStartDelay
public long getTriggerStartDelay()
isDeleteJob
public boolean isDeleteJob()
isPauseJob
public boolean isPauseJob()
setPauseJob
public void setPauseJob(boolean pauseJob)
setTriggerStartDelay
public void setTriggerStartDelay(long triggerStartDelay)
setDeleteJob
public void setDeleteJob(boolean deleteJob)
setFireNow
public void setFireNow(boolean fireNow)
setStateful
public void setStateful(boolean stateful)
isDurableJob
public boolean isDurableJob()
setDurableJob
public void setDurableJob(boolean durableJob)
isRecoverableJob
public boolean isRecoverableJob()
setRecoverableJob
public void setRecoverableJob(boolean recoverableJob)
setTriggerParameters
public void setTriggerParameters(Map<String,Object> triggerParameters)
setJobParameters
public void setJobParameters(Map<String,Object> jobParameters)
getConsumerLoadBalancer
public org.apache.camel.processor.loadbalancer.LoadBalancer getConsumerLoadBalancer()
setConsumerLoadBalancer
public void setConsumerLoadBalancer(org.apache.camel.processor.loadbalancer.LoadBalancer consumerLoadBalancer)
setCron
public void setCron(String cron)
getTriggerKey
public org.quartz.TriggerKey getTriggerKey()
setTriggerKey
public void setTriggerKey(org.quartz.TriggerKey triggerKey)
createProducer
public org.apache.camel.Producer createProducer()
throws Exception
- Throws:
Exception
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
throws Exception
- Throws:
Exception
isSingleton
public boolean isSingleton()
doStart
protected void doStart()
throws Exception
- Overrides:
doStart
in class org.apache.camel.impl.DefaultEndpoint
- Throws:
Exception
doStop
protected void doStop()
throws Exception
- Overrides:
doStop
in class org.apache.camel.impl.DefaultEndpoint
- Throws:
Exception
getComponent
public QuartzComponent getComponent()
- Overrides:
getComponent
in class org.apache.camel.impl.DefaultEndpoint
pauseTrigger
public void pauseTrigger()
throws Exception
- Throws:
Exception
resumeTrigger
public void resumeTrigger()
throws Exception
- Throws:
Exception
onConsumerStart
public void onConsumerStart(QuartzConsumer quartzConsumer)
throws Exception
- Throws:
Exception
onConsumerStop
public void onConsumerStop(QuartzConsumer quartzConsumer)
throws Exception
- Throws:
Exception
Apache Camel