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.core.jmx | |
org.quartz.impl.jdbcjobstore | |
org.quartz.impl.jdbcjobstore.oracle | |
org.quartz.impl.triggers |
This package contains Trigger implementations that ship with Quartz.
|
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.
|
org.terracotta.quartz | |
org.terracotta.quartz.wrappers |
Modifier and Type | Method and Description |
---|---|
static Date |
TriggerUtils.computeEndTimeToAllowParticularNumberOfFirings(OperableTrigger trigg,
Calendar cal,
int numTimes)
Compute the
Date that is 1 second after the Nth firing of
the given Trigger , taking the triger's associated
Calendar into consideration. |
static List<Date> |
TriggerUtils.computeFireTimes(OperableTrigger trigg,
Calendar cal,
int numTimes)
Returns a list of Dates that are the next fire times of a
Trigger . |
static List<Date> |
TriggerUtils.computeFireTimesBetween(OperableTrigger trigg,
Calendar cal,
Date from,
Date to)
Returns a list of Dates that are the next fire times of a
Trigger
that fall within the given date range. |
Modifier and Type | Method and Description |
---|---|
protected void |
QuartzScheduler.notifyJobStoreJobComplete(OperableTrigger trigger,
JobDetail detail,
Trigger.CompletedExecutionInstruction instCode) |
protected void |
QuartzScheduler.notifyJobStoreJobVetoed(OperableTrigger trigger,
JobDetail detail,
Trigger.CompletedExecutionInstruction instCode) |
void |
RemotableQuartzScheduler.triggerJob(OperableTrigger trig) |
void |
QuartzScheduler.triggerJob(OperableTrigger trig)
Store and schedule the identified
|
Modifier and Type | Method and Description |
---|---|
static OperableTrigger |
TriggerSupport.newTrigger(CompositeData cData) |
static OperableTrigger |
SimpleTriggerSupport.newTrigger(CompositeData cData) |
static OperableTrigger |
CronTriggerSupport.newTrigger(CompositeData cData) |
static OperableTrigger |
TriggerSupport.newTrigger(Map<String,Object> attrMap) |
static OperableTrigger |
SimpleTriggerSupport.newTrigger(Map<String,Object> attrMap) |
static OperableTrigger |
CronTriggerSupport.newTrigger(Map<String,Object> attrMap) |
Modifier and Type | Method and Description |
---|---|
protected OperableTrigger |
JobStoreSupport.retrieveTrigger(Connection conn,
TriggerKey key) |
OperableTrigger |
JobStoreSupport.retrieveTrigger(TriggerKey triggerKey)
Retrieve the given
. |
OperableTrigger |
StdJDBCDelegate.selectTrigger(Connection conn,
TriggerKey triggerKey)
Select a trigger.
|
OperableTrigger |
DriverDelegate.selectTrigger(Connection conn,
TriggerKey triggerKey)
Select a trigger.
|
Modifier and Type | Method and Description |
---|---|
protected List<OperableTrigger> |
JobStoreSupport.acquireNextTrigger(Connection conn,
long noLaterThan,
int maxCount,
long timeWindow) |
List<OperableTrigger> |
JobStoreSupport.acquireNextTriggers(long noLaterThan,
int maxCount,
long timeWindow)
Get a handle to the next N triggers to be fired, and mark them as 'reserved'
by the calling scheduler.
|
protected List<OperableTrigger> |
JobStoreSupport.getTriggersForJob(Connection conn,
JobKey key) |
List<OperableTrigger> |
JobStoreSupport.getTriggersForJob(JobKey jobKey)
Get all of the Triggers that are associated to the given Job.
|
List<OperableTrigger> |
StdJDBCDelegate.selectTriggersForCalendar(Connection conn,
String calName) |
List<OperableTrigger> |
DriverDelegate.selectTriggersForCalendar(Connection conn,
String calName)
Select the triggers for a calendar
|
List<OperableTrigger> |
StdJDBCDelegate.selectTriggersForJob(Connection conn,
JobKey jobKey)
Select the triggers for a job
|
List<OperableTrigger> |
DriverDelegate.selectTriggersForJob(Connection conn,
JobKey jobKey)
Select the triggers for a job
|
List<OperableTrigger> |
StdJDBCDelegate.selectTriggersForRecoveringJobs(Connection conn)
Select all of the triggers for jobs that are requesting recovery.
|
List<OperableTrigger> |
DriverDelegate.selectTriggersForRecoveringJobs(Connection conn)
Select all of the triggers for jobs that are requesting recovery.
|
Modifier and Type | Method and Description |
---|---|
boolean |
TriggerPersistenceDelegate.canHandleTriggerType(OperableTrigger trigger) |
boolean |
SimpleTriggerPersistenceDelegate.canHandleTriggerType(OperableTrigger trigger) |
boolean |
DailyTimeIntervalTriggerPersistenceDelegate.canHandleTriggerType(OperableTrigger trigger) |
boolean |
CronTriggerPersistenceDelegate.canHandleTriggerType(OperableTrigger trigger) |
boolean |
CalendarIntervalTriggerPersistenceDelegate.canHandleTriggerType(OperableTrigger trigger) |
TriggerPersistenceDelegate |
StdJDBCDelegate.findTriggerPersistenceDelegate(OperableTrigger trigger) |
protected abstract SimplePropertiesTriggerProperties |
SimplePropertiesTriggerPersistenceDelegateSupport.getTriggerProperties(OperableTrigger trigger) |
protected SimplePropertiesTriggerProperties |
DailyTimeIntervalTriggerPersistenceDelegate.getTriggerProperties(OperableTrigger trigger) |
protected SimplePropertiesTriggerProperties |
CalendarIntervalTriggerPersistenceDelegate.getTriggerProperties(OperableTrigger trigger) |
int |
StdJDBCDelegate.insertBlobTrigger(Connection conn,
OperableTrigger trigger)
Insert the blob trigger data.
|
int |
TriggerPersistenceDelegate.insertExtendedTriggerProperties(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail) |
int |
SimpleTriggerPersistenceDelegate.insertExtendedTriggerProperties(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail) |
int |
SimplePropertiesTriggerPersistenceDelegateSupport.insertExtendedTriggerProperties(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail) |
int |
CronTriggerPersistenceDelegate.insertExtendedTriggerProperties(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail) |
int |
StdJDBCDelegate.insertFiredTrigger(Connection conn,
OperableTrigger trigger,
String state,
JobDetail job)
Insert a fired trigger.
|
int |
DriverDelegate.insertFiredTrigger(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail)
Insert a fired trigger.
|
int |
StdJDBCDelegate.insertTrigger(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail)
Insert the base trigger data.
|
int |
PointbaseDelegate.insertTrigger(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail) |
int |
DriverDelegate.insertTrigger(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail)
Insert the base trigger data.
|
protected void |
JobStoreSupport.releaseAcquiredTrigger(Connection conn,
OperableTrigger trigger) |
void |
JobStoreSupport.releaseAcquiredTrigger(OperableTrigger trigger)
Inform the
JobStore that the scheduler no longer plans to
fire the given Trigger , that it had previously acquired
(reserved). |
protected boolean |
JobStoreSupport.replaceTrigger(Connection conn,
TriggerKey key,
OperableTrigger newTrigger) |
boolean |
JobStoreSupport.replaceTrigger(TriggerKey triggerKey,
OperableTrigger newTrigger) |
void |
JobStoreSupport.storeJobAndTrigger(JobDetail newJob,
OperableTrigger newTrigger)
|
protected void |
JobStoreSupport.storeTrigger(Connection conn,
OperableTrigger newTrigger,
JobDetail job,
boolean replaceExisting,
String state,
boolean forceState,
boolean recovering)
Insert or update a trigger.
|
void |
JobStoreSupport.storeTrigger(OperableTrigger newTrigger,
boolean replaceExisting)
Store the given
. |
protected void |
JobStoreSupport.triggeredJobComplete(Connection conn,
OperableTrigger trigger,
JobDetail jobDetail,
Trigger.CompletedExecutionInstruction triggerInstCode) |
void |
JobStoreSupport.triggeredJobComplete(OperableTrigger trigger,
JobDetail jobDetail,
Trigger.CompletedExecutionInstruction 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 TriggerFiredBundle |
JobStoreSupport.triggerFired(Connection conn,
OperableTrigger trigger) |
int |
StdJDBCDelegate.updateBlobTrigger(Connection conn,
OperableTrigger trigger)
Update the blob trigger data.
|
int |
TriggerPersistenceDelegate.updateExtendedTriggerProperties(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail) |
int |
SimpleTriggerPersistenceDelegate.updateExtendedTriggerProperties(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail) |
int |
SimplePropertiesTriggerPersistenceDelegateSupport.updateExtendedTriggerProperties(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail) |
int |
CronTriggerPersistenceDelegate.updateExtendedTriggerProperties(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail) |
int |
StdJDBCDelegate.updateFiredTrigger(Connection conn,
OperableTrigger trigger,
String state,
JobDetail job)
Update a fired trigger.
|
int |
DriverDelegate.updateFiredTrigger(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail)
Update a fired trigger record.
|
int |
StdJDBCDelegate.updateTrigger(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail)
Update the base trigger data.
|
int |
PointbaseDelegate.updateTrigger(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail) |
int |
DriverDelegate.updateTrigger(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail)
Update the base trigger data.
|
Modifier and Type | Method and Description |
---|---|
List<TriggerFiredResult> |
JobStoreSupport.triggersFired(List<OperableTrigger> triggers)
Inform the
JobStore that the scheduler is now firing the
given Trigger (executing its associated Job ),
that it had previously acquired (reserved). |
Modifier and Type | Method and Description |
---|---|
int |
OracleDelegate.insertTrigger(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail) |
int |
OracleDelegate.updateTrigger(Connection conn,
OperableTrigger trigger,
String state,
JobDetail jobDetail) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractTrigger<T extends Trigger>
The base abstract class to be extended by all
Trigger s. |
class |
CalendarIntervalTriggerImpl
|
class |
CronTriggerImpl
|
class |
DailyTimeIntervalTriggerImpl
A concrete implementation of DailyTimeIntervalTrigger that is used to fire a
based upon daily repeating time intervals. |
class |
SimpleTriggerImpl
|
Modifier and Type | Method and Description |
---|---|
OperableTrigger |
RAMJobStore.retrieveTrigger(TriggerKey triggerKey)
Retrieve the given
. |
Modifier and Type | Method and Description |
---|---|
List<OperableTrigger> |
RAMJobStore.acquireNextTriggers(long noLaterThan,
int maxCount,
long timeWindow)
Get a handle to the next trigger to be fired, and mark it as 'reserved'
by the calling scheduler.
|
List<OperableTrigger> |
RAMJobStore.getTriggersForJob(JobKey jobKey)
Get all of the Triggers that are associated to the given Job.
|
Modifier and Type | Method and Description |
---|---|
void |
RAMJobStore.releaseAcquiredTrigger(OperableTrigger trigger)
Inform the
JobStore that the scheduler no longer plans to
fire the given Trigger , that it had previously acquired
(reserved). |
boolean |
RAMJobStore.replaceTrigger(TriggerKey triggerKey,
OperableTrigger newTrigger) |
void |
RAMJobStore.storeJobAndTrigger(JobDetail newJob,
OperableTrigger newTrigger)
|
void |
RAMJobStore.storeTrigger(OperableTrigger newTrigger,
boolean replaceExisting)
Store the given
. |
void |
RAMJobStore.triggeredJobComplete(OperableTrigger trigger,
JobDetail jobDetail,
Trigger.CompletedExecutionInstruction 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. |
Modifier and Type | Method and Description |
---|---|
List<TriggerFiredResult> |
RAMJobStore.triggersFired(List<OperableTrigger> firedTriggers)
Inform the
JobStore that the scheduler is now firing the
given Trigger (executing its associated Job ),
that it had previously acquired (reserved). |
Modifier and Type | Method and Description |
---|---|
OperableTrigger |
TriggerFiredBundle.getTrigger() |
OperableTrigger |
JobStore.retrieveTrigger(TriggerKey triggerKey)
Retrieve the given
. |
Modifier and Type | Method and Description |
---|---|
List<OperableTrigger> |
JobStore.acquireNextTriggers(long noLaterThan,
int maxCount,
long timeWindow)
Get a handle to the next trigger to be fired, and mark it as 'reserved'
by the calling scheduler.
|
List<OperableTrigger> |
JobStore.getTriggersForJob(JobKey jobKey)
Get all of the Triggers that are associated to the given Job.
|
Modifier and Type | Method and Description |
---|---|
void |
JobStore.releaseAcquiredTrigger(OperableTrigger trigger)
Inform the
JobStore that the scheduler no longer plans to
fire the given Trigger , that it had previously acquired
(reserved). |
boolean |
JobStore.replaceTrigger(TriggerKey triggerKey,
OperableTrigger newTrigger)
Remove (delete) the
with the
given key, and store the new given one - which must be associated
with the same job. |
void |
JobStore.storeJobAndTrigger(JobDetail newJob,
OperableTrigger newTrigger)
|
void |
JobStore.storeTrigger(OperableTrigger newTrigger,
boolean replaceExisting)
Store the given
. |
void |
JobStore.triggeredJobComplete(OperableTrigger trigger,
JobDetail jobDetail,
Trigger.CompletedExecutionInstruction 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. |
Modifier and Type | Method and Description |
---|---|
List<TriggerFiredResult> |
JobStore.triggersFired(List<OperableTrigger> triggers)
Inform the
JobStore that the scheduler is now firing the
given Trigger (executing its associated Job ),
that it had previously acquired (reserved). |
Constructor and Description |
---|
TriggerFiredBundle(JobDetail job,
OperableTrigger trigger,
Calendar cal,
boolean jobIsRecovering,
Date fireTime,
Date scheduledFireTime,
Date prevFireTime,
Date nextFireTime) |
Modifier and Type | Method and Description |
---|---|
OperableTrigger |
PlainTerracottaJobStore.retrieveTrigger(TriggerKey triggerKey) |
OperableTrigger |
AbstractTerracottaJobStore.retrieveTrigger(TriggerKey triggerKey) |
Modifier and Type | Method and Description |
---|---|
List<OperableTrigger> |
PlainTerracottaJobStore.acquireNextTriggers(long noLaterThan,
int maxCount,
long timeWindow) |
List<OperableTrigger> |
AbstractTerracottaJobStore.acquireNextTriggers(long noLaterThan,
int maxCount,
long timeWindow) |
List<OperableTrigger> |
PlainTerracottaJobStore.getTriggersForJob(JobKey jobKey) |
List<OperableTrigger> |
AbstractTerracottaJobStore.getTriggersForJob(JobKey jobKey) |
Modifier and Type | Method and Description |
---|---|
void |
PlainTerracottaJobStore.releaseAcquiredTrigger(OperableTrigger trigger) |
void |
AbstractTerracottaJobStore.releaseAcquiredTrigger(OperableTrigger trigger) |
boolean |
PlainTerracottaJobStore.replaceTrigger(TriggerKey triggerKey,
OperableTrigger newTrigger) |
boolean |
AbstractTerracottaJobStore.replaceTrigger(TriggerKey triggerKey,
OperableTrigger newTrigger) |
void |
PlainTerracottaJobStore.storeJobAndTrigger(JobDetail newJob,
OperableTrigger newTrigger) |
void |
AbstractTerracottaJobStore.storeJobAndTrigger(JobDetail newJob,
OperableTrigger newTrigger) |
void |
PlainTerracottaJobStore.storeTrigger(OperableTrigger newTrigger,
boolean replaceExisting) |
void |
AbstractTerracottaJobStore.storeTrigger(OperableTrigger newTrigger,
boolean replaceExisting) |
void |
PlainTerracottaJobStore.triggeredJobComplete(OperableTrigger trigger,
JobDetail jobDetail,
Trigger.CompletedExecutionInstruction triggerInstCode) |
void |
AbstractTerracottaJobStore.triggeredJobComplete(OperableTrigger trigger,
JobDetail jobDetail,
Trigger.CompletedExecutionInstruction instruction) |
Modifier and Type | Method and Description |
---|---|
List<TriggerFiredResult> |
PlainTerracottaJobStore.triggersFired(List<OperableTrigger> triggers) |
List<TriggerFiredResult> |
AbstractTerracottaJobStore.triggersFired(List<OperableTrigger> triggers) |
Modifier and Type | Field and Description |
---|---|
protected OperableTrigger |
TriggerWrapper.trigger |
Modifier and Type | Method and Description |
---|---|
OperableTrigger |
TriggerWrapper.getTriggerClone() |
Modifier and Type | Method and Description |
---|---|
TriggerWrapper |
WrapperFactory.createTriggerWrapper(OperableTrigger trigger,
boolean jobDisallowsConcurrence) |
TriggerWrapper |
DefaultWrapperFactory.createTriggerWrapper(OperableTrigger trigger,
boolean jobDisallowsConcurrence) |
Constructor and Description |
---|
TriggerWrapper(OperableTrigger trigger,
boolean jobDisallowsConcurrence) |
Copyright 2001-2019, Terracotta, Inc.