org.apache.camel.component.quartz
Class QuartzEndpoint

java.lang.Object
  extended by org.apache.camel.impl.DefaultEndpoint<QuartzExchange>
      extended by 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 $

Field Summary
static String ENDPOINT_KEY
           
 
Constructor Summary
QuartzEndpoint(String endpointUri, QuartzComponent component, org.quartz.Scheduler scheduler)
           
 
Method Summary
 void addTrigger(org.quartz.Trigger trigger, org.quartz.JobDetail detail)
           
 void addTriggers(Map<org.quartz.Trigger,org.quartz.JobDetail> triggerMap)
           
 void consumerStarted(QuartzConsumer consumer)
           
 void consumerStopped(QuartzConsumer consumer)
           
 QuartzConsumer createConsumer(org.apache.camel.Processor processor)
           
 QuartzExchange createExchange()
           
 QuartzExchange createExchange(org.quartz.JobExecutionContext jobExecutionContext)
           
protected  org.quartz.JobDetail createJobDetail()
           
protected  org.apache.camel.processor.loadbalancer.LoadBalancer createLoadBalancer()
           
 org.apache.camel.Producer<QuartzExchange> createProducer()
           
protected  org.quartz.Trigger createTrigger()
           
 QuartzComponent getComponent()
           
 org.quartz.JobDetail getJobDetail()
           
 org.apache.camel.processor.loadbalancer.LoadBalancer getLoadBalancer()
           
 org.quartz.Scheduler getScheduler()
           
 org.quartz.Trigger getTrigger()
           
 boolean isSingleton()
           
 void onJobExecute(org.quartz.JobExecutionContext jobExecutionContext)
          This method is invoked when a Quartz job is fired.
 void removeTrigger(org.quartz.Trigger trigger, org.quartz.JobDetail jobDetail)
           
 void setJobDetail(org.quartz.JobDetail jobDetail)
           
 void setLoadBalancer(org.apache.camel.processor.loadbalancer.LoadBalancer loadBalancer)
           
 void setTrigger(org.quartz.Trigger trigger)
           
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
convertTo, createExchange, createExecutorService, createPollingConsumer, equals, getContext, getEndpointUri, getExchangeType, getExecutorService, hashCode, setExecutorService, toExchangeType, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Field Detail

ENDPOINT_KEY

public static final String ENDPOINT_KEY
See Also:
Constant Field Values
Constructor Detail

QuartzEndpoint

public QuartzEndpoint(String endpointUri,
                      QuartzComponent component,
                      org.quartz.Scheduler scheduler)
Method Detail

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.