public class QuartzComponent
extends org.apache.camel.impl.UriEndpointComponent
implements org.apache.camel.StartupListener
Constructor and Description |
---|
QuartzComponent() |
QuartzComponent(org.apache.camel.CamelContext context) |
Modifier and Type | Method and Description |
---|---|
void |
addJob(org.quartz.JobDetail job,
org.quartz.Trigger trigger) |
protected org.quartz.CronTrigger |
createCronTrigger(String path) |
protected QuartzEndpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> parameters) |
protected String |
createInstanceName(Properties prop) |
protected org.quartz.Scheduler |
createScheduler() |
protected org.quartz.SchedulerFactory |
createSchedulerFactory() |
void |
deleteJob(String name,
String group) |
protected void |
doStart() |
protected void |
doStop() |
org.quartz.SchedulerFactory |
getFactory() |
Properties |
getProperties() |
String |
getPropertiesFile() |
org.quartz.Scheduler |
getScheduler() |
int |
getStartDelayedSeconds() |
boolean |
isAutoStartScheduler() |
boolean |
isClustered()
Is the quartz scheduler clustered?
|
boolean |
isEnableJmx() |
protected Properties |
loadProperties() |
void |
onCamelContextStarted(org.apache.camel.CamelContext camelContext,
boolean alreadyStarted) |
void |
pauseJob(org.quartz.Trigger trigger) |
void |
setAutoStartScheduler(boolean autoStartScheduler)
Whether or not the scheduler should be auto started.
|
void |
setEnableJmx(boolean enableJmx)
Whether to enable Quartz JMX which allows to manage the Quartz scheduler from JMX.
|
void |
setFactory(org.quartz.SchedulerFactory factory)
To use the custom SchedulerFactory which is used to create the Scheduler.
|
void |
setProperties(Properties properties)
Properties to configure the Quartz scheduler.
|
void |
setPropertiesFile(String propertiesFile)
File name of the properties to load from the classpath
|
void |
setScheduler(org.quartz.Scheduler scheduler)
To use the custom configured Quartz scheduler, instead of creating a new Scheduler.
|
void |
setStartDelayedSeconds(int startDelayedSeconds)
Seconds to wait before starting the quartz scheduler.
|
void |
shutdownScheduler()
To force shutdown the quartz scheduler
|
void |
startScheduler()
To force starting the quartz scheduler
|
createComponentConfiguration, createParameterConfigurationMap, getEndpointClass, getParameterConfigurationMap, populateParameterConfigurationMap, setEndpointClass
afterConfiguration, createConfiguration, createEndpoint, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isResolvePropertyPlaceholders, preProcessUri, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, setResolvePropertyPlaceholders, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
public QuartzComponent()
public QuartzComponent(org.apache.camel.CamelContext context)
protected QuartzEndpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
Exception
protected org.quartz.CronTrigger createCronTrigger(String path) throws ParseException
ParseException
public void onCamelContextStarted(org.apache.camel.CamelContext camelContext, boolean alreadyStarted) throws Exception
onCamelContextStarted
in interface org.apache.camel.StartupListener
Exception
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultComponent
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultComponent
Exception
public void addJob(org.quartz.JobDetail job, org.quartz.Trigger trigger) throws org.quartz.SchedulerException
org.quartz.SchedulerException
public void pauseJob(org.quartz.Trigger trigger) throws org.quartz.SchedulerException
org.quartz.SchedulerException
public void deleteJob(String name, String group) throws org.quartz.SchedulerException
org.quartz.SchedulerException
public void shutdownScheduler() throws org.quartz.SchedulerException
org.quartz.SchedulerException
- can be thrown if error shutting downpublic boolean isClustered() throws org.quartz.SchedulerException
org.quartz.SchedulerException
public void startScheduler() throws org.quartz.SchedulerException
org.quartz.SchedulerException
- can be thrown if error startingpublic org.quartz.SchedulerFactory getFactory() throws org.quartz.SchedulerException
org.quartz.SchedulerException
public void setFactory(org.quartz.SchedulerFactory factory)
public org.quartz.Scheduler getScheduler() throws org.quartz.SchedulerException
org.quartz.SchedulerException
public void setScheduler(org.quartz.Scheduler scheduler)
public Properties getProperties()
public void setProperties(Properties properties)
public String getPropertiesFile()
public void setPropertiesFile(String propertiesFile)
public int getStartDelayedSeconds()
public void setStartDelayedSeconds(int startDelayedSeconds)
public boolean isAutoStartScheduler()
public void setAutoStartScheduler(boolean autoStartScheduler)
public boolean isEnableJmx()
public void setEnableJmx(boolean enableJmx)
protected Properties loadProperties() throws org.quartz.SchedulerException
org.quartz.SchedulerException
protected org.quartz.SchedulerFactory createSchedulerFactory() throws org.quartz.SchedulerException
org.quartz.SchedulerException
protected String createInstanceName(Properties prop)
protected org.quartz.Scheduler createScheduler() throws org.quartz.SchedulerException
org.quartz.SchedulerException
Apache Camel