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.

Field Summary

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

QuartzEndpoint(String uri, QuartzComponent quartzComponent)

Method Summary

org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
protected void	doStart()
protected void	doStop()
QuartzComponent	getComponent()
org.apache.camel.processor.loadbalancer.LoadBalancer	getConsumerLoadBalancer()
String	getCron()
org.quartz.TriggerKey	getTriggerKey()
long	getTriggerStartDelay()
boolean	isDeleteJob()
boolean	isDurableJob()
boolean	isFireNow()
boolean	isPauseJob()
boolean	isRecoverableJob()
boolean	isSingleton()
boolean	isStateful()
void	onConsumerStart(QuartzConsumer quartzConsumer)
void	onConsumerStop(QuartzConsumer quartzConsumer)
void	pauseTrigger()
void	resumeTrigger()
void	setConsumerLoadBalancer(org.apache.camel.processor.loadbalancer.LoadBalancer consumerLoadBalancer)
void	setCron(String cron)
void	setDeleteJob(boolean deleteJob)
void	setDurableJob(boolean durableJob)
void	setFireNow(boolean fireNow)
void	setJobParameters(Map<String,Object> jobParameters)
void	setPauseJob(boolean pauseJob)
void	setRecoverableJob(boolean recoverableJob)
void	setStateful(boolean stateful)
void	setTriggerKey(org.quartz.TriggerKey triggerKey)
void	setTriggerParameters(Map<String,Object> triggerParameters)
void	setTriggerStartDelay(long triggerStartDelay)

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 class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

QuartzEndpoint

public QuartzEndpoint(String uri,
                      QuartzComponent quartzComponent)

Method Detail

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