org.apache.camel.component.quartz
Class QuartzEndpoint

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by 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:

Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
QuartzEndpoint(String endpointUri, QuartzComponent component)
           
 
Method Summary
 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()
           
 org.quartz.JobDetail getJobDetail()
           
protected  String getJobName()
           
 org.apache.camel.processor.loadbalancer.LoadBalancer getLoadBalancer()
           
 org.quartz.Trigger getTrigger()
           
 boolean isDeleteJob()
           
 boolean isPauseJob()
           
 boolean isSingleton()
           
 boolean isStateful()
           
 void onJobExecute(org.quartz.JobExecutionContext jobExecutionContext)
          This method is invoked when a Quartz job is fired.
 void pauseTrigger(org.quartz.Trigger trigger)
           
 void setDeleteJob(boolean deleteJob)
           
 void setJobDetail(org.quartz.JobDetail jobDetail)
           
 void setLoadBalancer(org.apache.camel.processor.loadbalancer.LoadBalancer loadBalancer)
           
 void setPauseJob(boolean pauseJob)
           
 void setStateful(boolean stateful)
           
 void setTrigger(org.quartz.Trigger trigger)
           
 
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 class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.ShutdownableService
shutdown
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

QuartzEndpoint

public QuartzEndpoint(String endpointUri,
                      QuartzComponent component)
Method Detail

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