org.apache.camel.component.quartz
Class QuartzEndpoint
java.lang.Object
org.apache.camel.impl.DefaultEndpoint<QuartzExchange>
org.apache.camel.component.quartz.QuartzEndpoint
- All Implemented Interfaces:
- org.apache.camel.Endpoint<QuartzExchange>
public class QuartzEndpoint
- extends org.apache.camel.impl.DefaultEndpoint<QuartzExchange>
A Quartz Endpoint
- Version:
- $Revision:520964 $
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
convertTo, createExchange, createExecutorService, createPollingConsumer, equals, getContext, getEndpointUri, getExchangeType, getExecutorService, hashCode, setExecutorService, toExchangeType, toString |
ENDPOINT_KEY
public static final String ENDPOINT_KEY
- See Also:
- Constant Field Values
QuartzEndpoint
public QuartzEndpoint(String endpointUri,
QuartzComponent component,
org.quartz.Scheduler scheduler)
addTriggers
public void addTriggers(Map<org.quartz.Trigger,org.quartz.JobDetail> triggerMap)
throws org.quartz.SchedulerException
- Throws:
org.quartz.SchedulerException
addTrigger
public void addTrigger(org.quartz.Trigger trigger,
org.quartz.JobDetail detail)
throws org.quartz.SchedulerException
- Throws:
org.quartz.SchedulerException
removeTrigger
public void removeTrigger(org.quartz.Trigger trigger,
org.quartz.JobDetail jobDetail)
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 QuartzExchange createExchange()
createExchange
public QuartzExchange createExchange(org.quartz.JobExecutionContext jobExecutionContext)
createProducer
public org.apache.camel.Producer<QuartzExchange> createProducer()
throws Exception
- Throws:
Exception
createConsumer
public QuartzConsumer createConsumer(org.apache.camel.Processor processor)
throws Exception
- Throws:
Exception
getComponent
public QuartzComponent getComponent()
- Overrides:
getComponent
in class org.apache.camel.impl.DefaultEndpoint<QuartzExchange>
isSingleton
public boolean isSingleton()
getScheduler
public org.quartz.Scheduler getScheduler()
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)
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()
createJobDetail
protected org.quartz.JobDetail createJobDetail()
createTrigger
protected org.quartz.Trigger createTrigger()
Copyright © 2007 Apache Software Foundation. All Rights Reserved.