Package | Description |
---|---|
org.quartz |
The main package of Quartz, containing the client-side interfaces.
|
org.quartz.core |
Contains the core classes and interfaces for the Quartz job scheduler.
|
org.quartz.impl.jdbcjobstore | |
org.quartz.simpl |
Contains simple / light-weight implementations (with no dependencies on
external libraries) of interfaces required by the
org.quartz.core.QuartzScheduler.
|
org.quartz.spi |
Contains Service Provider Interfaces that can be implemented by those
wishing to create and use custom versions of Quartz back-end/behind-the-scenes
services.
|
Modifier and Type | Class and Description |
---|---|
class |
ObjectAlreadyExistsException
An exception that is thrown to indicate that an attempt to store a new
object (i.e.
|
Modifier and Type | Method and Description |
---|---|
protected void |
QuartzScheduler.notifyJobStoreJobComplete(SchedulingContext ctxt,
Trigger trigger,
JobDetail detail,
int instCode) |
protected void |
QuartzScheduler.notifyJobStoreJobVetoed(SchedulingContext ctxt,
Trigger trigger,
JobDetail detail,
int instCode) |
Modifier and Type | Class and Description |
---|---|
class |
LockException
Exception class for when there is a failure obtaining or releasing a
resource lock.
|
class |
NoSuchDelegateException
Exception class for when a driver delegate cannot be found for a given
configuration, or lack thereof.
|
Modifier and Type | Method and Description |
---|---|
protected Trigger |
JobStoreSupport.acquireNextTrigger(Connection conn,
SchedulingContext ctxt,
long noLaterThan) |
Trigger |
JobStoreSupport.acquireNextTrigger(SchedulingContext ctxt,
long noLaterThan)
Get a handle to the next N triggers to be fired, and mark them as 'reserved'
by the calling scheduler.
|
protected boolean |
JobStoreSupport.calendarExists(Connection conn,
String calName) |
protected String |
JobStoreSupport.checkBlockedState(Connection conn,
SchedulingContext ctxt,
String jobName,
String jobGroupName,
String currentState)
Determines if a Trigger for the given job should be blocked.
|
protected void |
JobStoreSupport.cleanVolatileTriggerAndJobs()
Removes all volatile data.
|
protected void |
JobStoreSupport.cleanVolatileTriggerAndJobs(Connection conn)
Removes all volatile data.
|
protected List |
JobStoreSupport.clusterCheckIn(Connection conn) |
protected void |
JobStoreSupport.clusterRecover(Connection conn,
List failedInstances) |
protected void |
JobStoreSupport.commitConnection(Connection conn)
Commit the supplied connection
|
protected boolean |
JobStoreSupport.doCheckin() |
protected JobStoreSupport.RecoverMisfiredJobsResult |
JobStoreSupport.doRecoverMisfires() |
Object |
JobStoreSupport.TransactionCallback.execute(Connection conn) |
void |
JobStoreSupport.VoidTransactionCallback.execute(Connection conn) |
protected Object |
JobStoreTX.executeInLock(String lockName,
JobStoreSupport.TransactionCallback txCallback)
Execute the given callback having optionally aquired the given lock.
|
protected abstract Object |
JobStoreSupport.executeInLock(String lockName,
JobStoreSupport.TransactionCallback txCallback)
Execute the given callback having aquired the given lock.
|
protected Object |
JobStoreCMT.executeInLock(String lockName,
JobStoreSupport.TransactionCallback txCallback)
Execute the given callback having optionally acquired the given lock.
|
protected void |
JobStoreSupport.executeInLock(String lockName,
JobStoreSupport.VoidTransactionCallback txCallback)
Execute the given callback having aquired the given lock.
|
protected Object |
JobStoreSupport.executeInNonManagedTXLock(String lockName,
JobStoreSupport.TransactionCallback txCallback)
Execute the given callback having optionally aquired the given lock.
|
protected void |
JobStoreSupport.executeInNonManagedTXLock(String lockName,
JobStoreSupport.VoidTransactionCallback txCallback)
Execute the given callback having optionally aquired the given lock.
|
Object |
JobStoreSupport.executeWithoutLock(JobStoreSupport.TransactionCallback txCallback)
Execute the given callback in a transaction.
|
protected List |
JobStoreSupport.findFailedInstances(Connection conn)
Get a list of all scheduler instances in the cluster that may have failed.
|
protected String[] |
JobStoreSupport.getCalendarNames(Connection conn,
SchedulingContext ctxt) |
String[] |
JobStoreSupport.getCalendarNames(SchedulingContext ctxt)
Get the names of all of the
s
in the JobStore . |
protected Connection |
JobStoreSupport.getConnection() |
protected String[] |
JobStoreSupport.getJobGroupNames(Connection conn,
SchedulingContext ctxt) |
String[] |
JobStoreSupport.getJobGroupNames(SchedulingContext ctxt)
Get the names of all of the
groups. |
protected String[] |
JobStoreSupport.getJobNames(Connection conn,
SchedulingContext ctxt,
String groupName) |
String[] |
JobStoreSupport.getJobNames(SchedulingContext ctxt,
String groupName)
Get the names of all of the
s that
have the given group name. |
protected Connection |
JobStoreTX.getNonManagedTXConnection()
For
JobStoreTX , the non-managed TX connection is just
the normal connection because it is not CMT. |
protected abstract Connection |
JobStoreSupport.getNonManagedTXConnection() |
protected Connection |
JobStoreCMT.getNonManagedTXConnection() |
protected int |
JobStoreSupport.getNumberOfCalendars(Connection conn,
SchedulingContext ctxt) |
int |
JobStoreSupport.getNumberOfCalendars(SchedulingContext ctxt)
Get the number of
s that are
stored in the JobsStore . |
protected int |
JobStoreSupport.getNumberOfJobs(Connection conn,
SchedulingContext ctxt) |
int |
JobStoreSupport.getNumberOfJobs(SchedulingContext ctxt)
Get the number of
s that are
stored in the JobStore . |
protected int |
JobStoreSupport.getNumberOfTriggers(Connection conn,
SchedulingContext ctxt) |
int |
JobStoreSupport.getNumberOfTriggers(SchedulingContext ctxt)
Get the number of
s that are
stored in the JobsStore . |
Set |
JobStoreSupport.getPausedTriggerGroups(Connection conn,
SchedulingContext ctxt)
Pause all of the
in the
given group. |
Set |
JobStoreSupport.getPausedTriggerGroups(SchedulingContext ctxt) |
protected String[] |
JobStoreSupport.getTriggerGroupNames(Connection conn,
SchedulingContext ctxt) |
String[] |
JobStoreSupport.getTriggerGroupNames(SchedulingContext ctxt)
Get the names of all of the
groups. |
protected String[] |
JobStoreSupport.getTriggerNames(Connection conn,
SchedulingContext ctxt,
String groupName) |
String[] |
JobStoreSupport.getTriggerNames(SchedulingContext ctxt,
String groupName)
Get the names of all of the
s
that have the given group name. |
protected Trigger[] |
JobStoreSupport.getTriggersForJob(Connection conn,
SchedulingContext ctxt,
String jobName,
String groupName) |
Trigger[] |
JobStoreSupport.getTriggersForJob(SchedulingContext ctxt,
String jobName,
String groupName)
Get all of the Triggers that are associated to the given Job.
|
int |
JobStoreSupport.getTriggerState(Connection conn,
SchedulingContext ctxt,
String triggerName,
String groupName) |
int |
JobStoreSupport.getTriggerState(SchedulingContext ctxt,
String triggerName,
String groupName)
Get the current state of the identified
. |
protected boolean |
JobStoreSupport.jobExists(Connection conn,
String jobName,
String groupName)
Check existence of a given job.
|
void |
JobStoreSupport.pauseAll(Connection conn,
SchedulingContext ctxt)
Pause all triggers - equivalent of calling
pauseTriggerGroup(group)
on every group. |
void |
JobStoreSupport.pauseAll(SchedulingContext ctxt)
Pause all triggers - equivalent of calling
pauseTriggerGroup(group)
on every group. |
void |
JobStoreSupport.pauseJob(SchedulingContext ctxt,
String jobName,
String groupName)
Pause the
with the given name - by
pausing all of its current Trigger s. |
void |
JobStoreSupport.pauseJobGroup(SchedulingContext ctxt,
String groupName)
Pause all of the
in the given
group - by pausing all of their Trigger s. |
void |
JobStoreSupport.pauseTrigger(Connection conn,
SchedulingContext ctxt,
String triggerName,
String groupName)
Pause the
with the given name. |
void |
JobStoreSupport.pauseTrigger(SchedulingContext ctxt,
String triggerName,
String groupName)
Pause the
with the given name. |
void |
JobStoreSupport.pauseTriggerGroup(Connection conn,
SchedulingContext ctxt,
String groupName)
Pause all of the
in the
given group. |
void |
JobStoreSupport.pauseTriggerGroup(SchedulingContext ctxt,
String groupName)
Pause all of the
in the
given group. |
protected void |
JobStoreSupport.recoverJobs()
Recover any failed or misfired jobs and clean up the data store as
appropriate.
|
protected void |
JobStoreSupport.recoverJobs(Connection conn)
Will recover any failed or misfired jobs and clean up the data store as
appropriate.
|
protected JobStoreSupport.RecoverMisfiredJobsResult |
JobStoreSupport.recoverMisfiredJobs(Connection conn,
boolean recovering) |
protected void |
JobStoreSupport.releaseAcquiredTrigger(Connection conn,
SchedulingContext ctxt,
Trigger trigger) |
void |
JobStoreSupport.releaseAcquiredTrigger(SchedulingContext ctxt,
Trigger trigger)
Inform the
JobStore that the scheduler no longer plans to
fire the given Trigger , that it had previously acquired
(reserved). |
protected boolean |
JobStoreSupport.removeCalendar(Connection conn,
SchedulingContext ctxt,
String calName) |
boolean |
JobStoreSupport.removeCalendar(SchedulingContext ctxt,
String calName)
Remove (delete) the
with the
given name. |
protected boolean |
JobStoreSupport.removeJob(Connection conn,
SchedulingContext ctxt,
String jobName,
String groupName,
boolean activeDeleteSafe) |
boolean |
JobStoreSupport.removeJob(SchedulingContext ctxt,
String jobName,
String groupName)
|
protected boolean |
JobStoreSupport.removeTrigger(Connection conn,
SchedulingContext ctxt,
String triggerName,
String groupName) |
boolean |
JobStoreSupport.removeTrigger(SchedulingContext ctxt,
String triggerName,
String groupName)
Remove (delete) the
with the
given name. |
protected boolean |
JobStoreSupport.replaceTrigger(Connection conn,
SchedulingContext ctxt,
String triggerName,
String groupName,
Trigger newTrigger) |
boolean |
JobStoreSupport.replaceTrigger(SchedulingContext ctxt,
String triggerName,
String groupName,
Trigger newTrigger) |
void |
JobStoreSupport.resumeAll(Connection conn,
SchedulingContext ctxt)
protected
|
void |
JobStoreSupport.resumeAll(SchedulingContext ctxt)
Resume (un-pause) all triggers - equivalent of calling
resumeTriggerGroup(group)
on every group. |
void |
JobStoreSupport.resumeJob(SchedulingContext ctxt,
String jobName,
String groupName)
Resume (un-pause) the
with the
given name. |
void |
JobStoreSupport.resumeJobGroup(SchedulingContext ctxt,
String groupName)
Resume (un-pause) all of the
in
the given group. |
void |
JobStoreSupport.resumeTrigger(Connection conn,
SchedulingContext ctxt,
String triggerName,
String groupName)
Resume (un-pause) the
with the
given name. |
void |
JobStoreSupport.resumeTrigger(SchedulingContext ctxt,
String triggerName,
String groupName)
Resume (un-pause) the
with the
given name. |
void |
JobStoreSupport.resumeTriggerGroup(Connection conn,
SchedulingContext ctxt,
String groupName)
Resume (un-pause) all of the
in the given group. |
void |
JobStoreSupport.resumeTriggerGroup(SchedulingContext ctxt,
String groupName)
Resume (un-pause) all of the
in the given group. |
protected Calendar |
JobStoreSupport.retrieveCalendar(Connection conn,
SchedulingContext ctxt,
String calName) |
Calendar |
JobStoreSupport.retrieveCalendar(SchedulingContext ctxt,
String calName)
Retrieve the given
. |
protected JobDetail |
JobStoreSupport.retrieveJob(Connection conn,
SchedulingContext ctxt,
String jobName,
String groupName) |
JobDetail |
JobStoreSupport.retrieveJob(SchedulingContext ctxt,
String jobName,
String groupName)
|
protected Trigger |
JobStoreSupport.retrieveTrigger(Connection conn,
SchedulingContext ctxt,
String triggerName,
String groupName) |
protected Trigger |
JobStoreSupport.retrieveTrigger(Connection conn,
String triggerName,
String groupName) |
Trigger |
JobStoreSupport.retrieveTrigger(SchedulingContext ctxt,
String triggerName,
String groupName)
Retrieve the given
. |
protected void |
JobStoreSupport.storeCalendar(Connection conn,
SchedulingContext ctxt,
String calName,
Calendar calendar,
boolean replaceExisting,
boolean updateTriggers) |
void |
JobStoreSupport.storeCalendar(SchedulingContext ctxt,
String calName,
Calendar calendar,
boolean replaceExisting,
boolean updateTriggers)
Store the given
. |
protected void |
JobStoreSupport.storeJob(Connection conn,
SchedulingContext ctxt,
JobDetail newJob,
boolean replaceExisting)
Insert or update a job.
|
void |
JobStoreSupport.storeJob(SchedulingContext ctxt,
JobDetail newJob,
boolean replaceExisting)
Store the given
. |
void |
JobStoreSupport.storeJobAndTrigger(SchedulingContext ctxt,
JobDetail newJob,
Trigger newTrigger)
|
protected void |
JobStoreSupport.storeTrigger(Connection conn,
SchedulingContext ctxt,
Trigger newTrigger,
JobDetail job,
boolean replaceExisting,
String state,
boolean forceState,
boolean recovering)
Insert or update a trigger.
|
void |
JobStoreSupport.storeTrigger(SchedulingContext ctxt,
Trigger newTrigger,
boolean replaceExisting)
Store the given
. |
protected void |
JobStoreSupport.triggeredJobComplete(Connection conn,
SchedulingContext ctxt,
Trigger trigger,
JobDetail jobDetail,
int triggerInstCode) |
void |
JobStoreSupport.triggeredJobComplete(SchedulingContext ctxt,
Trigger trigger,
JobDetail jobDetail,
int triggerInstCode)
Inform the
JobStore that the scheduler has completed the
firing of the given Trigger (and the execution its
associated Job ), and that the
in the given JobDetail should be updated if the Job
is stateful. |
protected boolean |
JobStoreSupport.triggerExists(Connection conn,
String triggerName,
String groupName)
Check existence of a given trigger.
|
protected TriggerFiredBundle |
JobStoreSupport.triggerFired(Connection conn,
SchedulingContext ctxt,
Trigger trigger) |
TriggerFiredBundle |
JobStoreSupport.triggerFired(SchedulingContext ctxt,
Trigger trigger)
Inform the
JobStore that the scheduler is now firing the
given Trigger (executing its associated Job ),
that it had previously acquired (reserved). |
protected boolean |
JobStoreSupport.updateMisfiredTrigger(Connection conn,
SchedulingContext ctxt,
String triggerName,
String groupName,
String newStateIfNotComplete,
boolean forceState) |
Modifier and Type | Method and Description |
---|---|
Set |
RAMJobStore.getPausedTriggerGroups(SchedulingContext ctxt) |
int |
RAMJobStore.getTriggerState(SchedulingContext ctxt,
String triggerName,
String groupName)
Get the current state of the identified
. |
boolean |
RAMJobStore.removeCalendar(SchedulingContext ctxt,
String calName)
Remove (delete) the
with the
given name. |
boolean |
RAMJobStore.replaceTrigger(SchedulingContext ctxt,
String triggerName,
String groupName,
Trigger newTrigger) |
void |
RAMJobStore.storeJobAndTrigger(SchedulingContext ctxt,
JobDetail newJob,
Trigger newTrigger)
|
void |
RAMJobStore.storeTrigger(SchedulingContext ctxt,
Trigger newTrigger,
boolean replaceExisting)
Store the given
. |
Modifier and Type | Method and Description |
---|---|
Trigger |
JobStore.acquireNextTrigger(SchedulingContext ctxt,
long noLaterThan)
Get a handle to the next trigger to be fired, and mark it as 'reserved'
by the calling scheduler.
|
String[] |
JobStore.getCalendarNames(SchedulingContext ctxt)
Get the names of all of the
s
in the JobStore . |
String[] |
JobStore.getJobGroupNames(SchedulingContext ctxt)
Get the names of all of the
groups. |
String[] |
JobStore.getJobNames(SchedulingContext ctxt,
String groupName)
Get the names of all of the
s that
have the given group name. |
int |
JobStore.getNumberOfCalendars(SchedulingContext ctxt)
Get the number of
s that are
stored in the JobsStore . |
int |
JobStore.getNumberOfJobs(SchedulingContext ctxt)
Get the number of
s that are
stored in the JobsStore . |
int |
JobStore.getNumberOfTriggers(SchedulingContext ctxt)
Get the number of
s that are
stored in the JobsStore . |
Set |
JobStore.getPausedTriggerGroups(SchedulingContext ctxt) |
String[] |
JobStore.getTriggerGroupNames(SchedulingContext ctxt)
Get the names of all of the
groups. |
String[] |
JobStore.getTriggerNames(SchedulingContext ctxt,
String groupName)
Get the names of all of the
s
that have the given group name. |
Trigger[] |
JobStore.getTriggersForJob(SchedulingContext ctxt,
String jobName,
String groupName)
Get all of the Triggers that are associated to the given Job.
|
int |
JobStore.getTriggerState(SchedulingContext ctxt,
String triggerName,
String triggerGroup)
Get the current state of the identified
. |
void |
JobStore.pauseAll(SchedulingContext ctxt)
Pause all triggers - equivalent of calling
pauseTriggerGroup(group)
on every group. |
void |
JobStore.pauseJob(SchedulingContext ctxt,
String jobName,
String groupName)
Pause the
with the given name - by
pausing all of its current Trigger s. |
void |
JobStore.pauseJobGroup(SchedulingContext ctxt,
String groupName)
Pause all of the
in the given
group - by pausing all of their Trigger s. |
void |
JobStore.pauseTrigger(SchedulingContext ctxt,
String triggerName,
String groupName)
Pause the
with the given name. |
void |
JobStore.pauseTriggerGroup(SchedulingContext ctxt,
String groupName)
Pause all of the
in the
given group. |
void |
JobStore.releaseAcquiredTrigger(SchedulingContext ctxt,
Trigger trigger)
Inform the
JobStore that the scheduler no longer plans to
fire the given Trigger , that it had previously acquired
(reserved). |
boolean |
JobStore.removeCalendar(SchedulingContext ctxt,
String calName)
Remove (delete) the
with the
given name. |
boolean |
JobStore.removeJob(SchedulingContext ctxt,
String jobName,
String groupName)
|
boolean |
JobStore.removeTrigger(SchedulingContext ctxt,
String triggerName,
String groupName)
Remove (delete) the
with the
given name. |
boolean |
JobStore.replaceTrigger(SchedulingContext ctxt,
String triggerName,
String groupName,
Trigger newTrigger)
Remove (delete) the
with the
given name, and store the new given one - which must be associated
with the same job. |
void |
JobStore.resumeAll(SchedulingContext ctxt)
Resume (un-pause) all triggers - equivalent of calling
resumeTriggerGroup(group)
on every group. |
void |
JobStore.resumeJob(SchedulingContext ctxt,
String jobName,
String groupName)
Resume (un-pause) the
with the
given name. |
void |
JobStore.resumeJobGroup(SchedulingContext ctxt,
String groupName)
Resume (un-pause) all of the
in
the given group. |
void |
JobStore.resumeTrigger(SchedulingContext ctxt,
String triggerName,
String groupName)
Resume (un-pause) the
with the
given name. |
void |
JobStore.resumeTriggerGroup(SchedulingContext ctxt,
String groupName)
Resume (un-pause) all of the
in the given group. |
Calendar |
JobStore.retrieveCalendar(SchedulingContext ctxt,
String calName)
Retrieve the given
. |
JobDetail |
JobStore.retrieveJob(SchedulingContext ctxt,
String jobName,
String groupName)
|
Trigger |
JobStore.retrieveTrigger(SchedulingContext ctxt,
String triggerName,
String groupName)
Retrieve the given
. |
void |
JobStore.storeCalendar(SchedulingContext ctxt,
String name,
Calendar calendar,
boolean replaceExisting,
boolean updateTriggers)
Store the given
. |
void |
JobStore.storeJob(SchedulingContext ctxt,
JobDetail newJob,
boolean replaceExisting)
Store the given
. |
void |
JobStore.storeJobAndTrigger(SchedulingContext ctxt,
JobDetail newJob,
Trigger newTrigger)
|
void |
JobStore.storeTrigger(SchedulingContext ctxt,
Trigger newTrigger,
boolean replaceExisting)
Store the given
. |
void |
JobStore.triggeredJobComplete(SchedulingContext ctxt,
Trigger trigger,
JobDetail jobDetail,
int triggerInstCode)
Inform the
JobStore that the scheduler has completed the
firing of the given Trigger (and the execution of its
associated Job completed, threw an exception, or was vetoed),
and that the
in the given JobDetail should be updated if the Job
is stateful. |
TriggerFiredBundle |
JobStore.triggerFired(SchedulingContext ctxt,
Trigger trigger)
Inform the
JobStore that the scheduler is now firing the
given Trigger (executing its associated Job ),
that it had previously acquired (reserved). |
Copyright © 2017. All rights reserved.