org.apache.camel.component.quartz
Class QuartzEndpoint
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultEndpoint
org.apache.camel.component.quartz.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
- implements org.apache.camel.ShutdownableService
A Quartz Endpoint
- Version:
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, 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, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from interface org.apache.camel.ShutdownableService |
shutdown |
Methods inherited from interface org.apache.camel.Service |
start, stop |
QuartzEndpoint
public QuartzEndpoint(String endpointUri,
QuartzComponent component)
addTrigger
public void addTrigger(org.quartz.Trigger trigger,
org.quartz.JobDetail detail)
throws org.quartz.SchedulerException
- Throws:
org.quartz.SchedulerException
pauseTrigger
public void pauseTrigger(org.quartz.Trigger trigger)
throws org.quartz.SchedulerException
- Throws:
org.quartz.SchedulerException
deleteTrigger
public void deleteTrigger(org.quartz.Trigger trigger)
throws org.quartz.SchedulerException
- Throws:
org.quartz.SchedulerException
onJobExecute
public void onJobExecute(org.quartz.JobExecutionContext jobExecutionContext)
throws org.quartz.JobExecutionException
- This method is invoked when a Quartz job is fired.
- Parameters:
jobExecutionContext
- the Quartz Job context
- Throws:
org.quartz.JobExecutionException
createExchange
public org.apache.camel.Exchange createExchange(org.quartz.JobExecutionContext jobExecutionContext)
createProducer
public org.apache.camel.Producer createProducer()
throws Exception
- Specified by:
createProducer
in interface org.apache.camel.Endpoint
- Throws:
Exception
createConsumer
public QuartzConsumer createConsumer(org.apache.camel.Processor processor)
throws Exception
- Specified by:
createConsumer
in interface org.apache.camel.Endpoint
- Throws:
Exception
createEndpointUri
protected String createEndpointUri()
- Overrides:
createEndpointUri
in class org.apache.camel.impl.DefaultEndpoint
getJobName
protected String getJobName()
getComponent
public QuartzComponent getComponent()
- Overrides:
getComponent
in class org.apache.camel.impl.DefaultEndpoint
isSingleton
public boolean isSingleton()
- Specified by:
isSingleton
in interface org.apache.camel.IsSingleton
getLoadBalancer
public org.apache.camel.processor.loadbalancer.LoadBalancer getLoadBalancer()
setLoadBalancer
public void setLoadBalancer(org.apache.camel.processor.loadbalancer.LoadBalancer loadBalancer)
getJobDetail
public org.quartz.JobDetail getJobDetail()
setJobDetail
public void setJobDetail(org.quartz.JobDetail jobDetail)
getTrigger
public org.quartz.Trigger getTrigger()
setTrigger
public void setTrigger(org.quartz.Trigger trigger)
isStateful
public boolean isStateful()
setStateful
public void setStateful(boolean stateful)
isDeleteJob
public boolean isDeleteJob()
setDeleteJob
public void setDeleteJob(boolean deleteJob)
isPauseJob
public boolean isPauseJob()
setPauseJob
public void setPauseJob(boolean pauseJob)
consumerStarted
public void consumerStarted(QuartzConsumer consumer)
throws org.quartz.SchedulerException
- Throws:
org.quartz.SchedulerException
consumerStopped
public void consumerStopped(QuartzConsumer consumer)
throws org.quartz.SchedulerException
- Throws:
org.quartz.SchedulerException
createLoadBalancer
protected org.apache.camel.processor.loadbalancer.LoadBalancer createLoadBalancer()
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
doShutdown
protected void doShutdown()
throws Exception
- Overrides:
doShutdown
in class org.apache.camel.support.ServiceSupport
- Throws:
Exception
Apache Camel