|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use JobPersistenceException | |
---|---|
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.locality | |
org.quartz.simpl | Contains simple / light-weight implementations (with no dependencies on external libraries) of interfaces required by the org.quartz.core.QuartzScheduler. |
Uses of JobPersistenceException in org.quartz |
---|
Subclasses of JobPersistenceException in org.quartz | |
---|---|
class |
ObjectAlreadyExistsException
An exception that is thrown to indicate that an attempt to store a new object (i.e. |
Uses of JobPersistenceException in org.quartz.core |
---|
Methods in org.quartz.core that throw JobPersistenceException | |
---|---|
protected void |
QuartzScheduler.notifyJobStoreJobComplete(org.quartz.spi.OperableTrigger trigger,
JobDetail detail,
Trigger.CompletedExecutionInstruction instCode)
|
protected void |
QuartzScheduler.notifyJobStoreJobVetoed(org.quartz.spi.OperableTrigger trigger,
JobDetail detail,
Trigger.CompletedExecutionInstruction instCode)
|
Uses of JobPersistenceException in org.quartz.impl.jdbcjobstore |
---|
Subclasses of JobPersistenceException in org.quartz.impl.jdbcjobstore | |
---|---|
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. |
Methods in org.quartz.impl.jdbcjobstore that throw JobPersistenceException | |
---|---|
protected List<org.quartz.spi.OperableTrigger> |
JobStoreSupport.acquireNextTrigger(Connection conn,
long noLaterThan,
int maxCount,
long timeWindow)
|
List<org.quartz.spi.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 boolean |
JobStoreSupport.calendarExists(Connection conn,
String calName)
|
protected String |
JobStoreSupport.checkBlockedState(Connection conn,
JobKey jobKey,
String currentState)
Determines if a Trigger for the given job should be blocked. |
protected boolean |
JobStoreSupport.checkExists(Connection conn,
JobKey jobKey)
|
protected boolean |
JobStoreSupport.checkExists(Connection conn,
TriggerKey triggerKey)
|
boolean |
JobStoreSupport.checkExists(JobKey jobKey)
Determine whether a Job with the given identifier already
exists within the scheduler. |
boolean |
JobStoreSupport.checkExists(TriggerKey triggerKey)
Determine whether a Trigger with the given identifier already
exists within the scheduler. |
void |
JobStoreSupport.clearAllSchedulingData()
Clear (delete!) all scheduling data - all Job s, Trigger s
Calendar s. |
protected void |
JobStoreSupport.clearAllSchedulingData(Connection conn)
|
protected List<SchedulerStateRecord> |
JobStoreSupport.clusterCheckIn(Connection conn)
|
protected void |
JobStoreSupport.clusterRecover(Connection conn,
List<SchedulerStateRecord> 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 |
JobStoreCMT.executeInLock(String lockName,
JobStoreSupport.TransactionCallback txCallback)
Execute the given callback having optionally acquired the given lock. |
protected abstract Object |
JobStoreSupport.executeInLock(String lockName,
JobStoreSupport.TransactionCallback txCallback)
Execute the given callback having acquired the given lock. |
protected Object |
JobStoreTX.executeInLock(String lockName,
JobStoreSupport.TransactionCallback txCallback)
Execute the given callback having optionally aquired the given lock. |
protected void |
JobStoreSupport.executeInLock(String lockName,
JobStoreSupport.VoidTransactionCallback txCallback)
Execute the given callback having acquired the given lock. |
protected Object |
JobStoreSupport.executeInNonManagedTXLock(String lockName,
JobStoreSupport.TransactionCallback txCallback)
Execute the given callback having optionally acquired the given lock. |
protected void |
JobStoreSupport.executeInNonManagedTXLock(String lockName,
JobStoreSupport.VoidTransactionCallback txCallback)
Execute the given callback having optionally acquired the given lock. |
Object |
JobStoreSupport.executeWithoutLock(JobStoreSupport.TransactionCallback txCallback)
Execute the given callback in a transaction. |
protected List<SchedulerStateRecord> |
JobStoreSupport.findFailedInstances(Connection conn)
Get a list of all scheduler instances in the cluster that may have failed. |
List<String> |
JobStoreSupport.getCalendarNames()
Get the names of all of the s
in the JobStore . |
protected List<String> |
JobStoreSupport.getCalendarNames(Connection conn)
|
protected Connection |
JobStoreSupport.getConnection()
|
List<String> |
JobStoreSupport.getJobGroupNames()
Get the names of all of the
groups. |
protected List<String> |
JobStoreSupport.getJobGroupNames(Connection conn)
|
Set<JobKey> |
JobStoreSupport.getJobKeys(GroupMatcher<JobKey> matcher)
Get the names of all of the s that
matcher the given groupMatcher. |
protected Set<JobKey> |
JobStoreSupport.getJobNames(Connection conn,
GroupMatcher<JobKey> matcher)
|
protected Connection |
JobStoreCMT.getNonManagedTXConnection()
|
protected abstract Connection |
JobStoreSupport.getNonManagedTXConnection()
|
protected Connection |
JobStoreTX.getNonManagedTXConnection()
For JobStoreTX , the non-managed TX connection is just
the normal connection because it is not CMT. |
int |
JobStoreSupport.getNumberOfCalendars()
Get the number of s that are
stored in the JobsStore . |
protected int |
JobStoreSupport.getNumberOfCalendars(Connection conn)
|
int |
JobStoreSupport.getNumberOfJobs()
Get the number of s that are
stored in the JobStore . |
protected int |
JobStoreSupport.getNumberOfJobs(Connection conn)
|
int |
JobStoreSupport.getNumberOfTriggers()
Get the number of s that are
stored in the JobsStore . |
protected int |
JobStoreSupport.getNumberOfTriggers(Connection conn)
|
Set<String> |
JobStoreSupport.getPausedTriggerGroups()
|
Set<String> |
JobStoreSupport.getPausedTriggerGroups(Connection conn)
Pause all of the in the
given group. |
List<String> |
JobStoreSupport.getTriggerGroupNames()
Get the names of all of the
groups. |
protected List<String> |
JobStoreSupport.getTriggerGroupNames(Connection conn)
|
Set<TriggerKey> |
JobStoreSupport.getTriggerKeys(GroupMatcher<TriggerKey> matcher)
Get the names of all of the s
that match the given group Matcher. |
protected Set<TriggerKey> |
JobStoreSupport.getTriggerNames(Connection conn,
GroupMatcher<TriggerKey> matcher)
|
protected List<org.quartz.spi.OperableTrigger> |
JobStoreSupport.getTriggersForJob(Connection conn,
JobKey key)
|
List<org.quartz.spi.OperableTrigger> |
JobStoreSupport.getTriggersForJob(JobKey jobKey)
Get all of the Triggers that are associated to the given Job. |
Trigger.TriggerState |
JobStoreSupport.getTriggerState(Connection conn,
TriggerKey key)
|
Trigger.TriggerState |
JobStoreSupport.getTriggerState(TriggerKey triggerKey)
Get the current state of the identified . |
protected boolean |
JobStoreSupport.jobExists(Connection conn,
JobKey jobKey)
Check existence of a given job. |
void |
JobStoreSupport.pauseAll()
Pause all triggers - equivalent of calling pauseTriggerGroup(group)
on every group. |
void |
JobStoreSupport.pauseAll(Connection conn)
Pause all triggers - equivalent of calling pauseTriggerGroup(group)
on every group. |
void |
JobStoreSupport.pauseJob(JobKey jobKey)
Pause the with the given name - by
pausing all of its current Trigger s. |
Set<String> |
JobStoreSupport.pauseJobs(GroupMatcher<JobKey> matcher)
Pause all of the matching the given
groupMatcher - by pausing all of their Trigger s. |
void |
JobStoreSupport.pauseTrigger(Connection conn,
TriggerKey triggerKey)
Pause the with the given name. |
void |
JobStoreSupport.pauseTrigger(TriggerKey triggerKey)
Pause the with the given name. |
Set<String> |
JobStoreSupport.pauseTriggerGroup(Connection conn,
GroupMatcher<TriggerKey> matcher)
Pause all of the matching the
given groupMatcher. |
Set<String> |
JobStoreSupport.pauseTriggers(GroupMatcher<TriggerKey> matcher)
Pause all of the matching the
given groupMatcher. |
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,
org.quartz.spi.OperableTrigger trigger)
|
void |
JobStoreSupport.releaseAcquiredTrigger(org.quartz.spi.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.removeCalendar(Connection conn,
String calName)
|
boolean |
JobStoreSupport.removeCalendar(String calName)
Remove (delete) the with the
given name. |
protected boolean |
JobStoreSupport.removeJob(Connection conn,
JobKey jobKey,
boolean activeDeleteSafe)
|
boolean |
JobStoreSupport.removeJob(JobKey jobKey)
Remove (delete) the with the given
name, and any s that reference
it. |
boolean |
JobStoreSupport.removeJobs(List<JobKey> jobKeys)
|
protected boolean |
JobStoreSupport.removeTrigger(Connection conn,
TriggerKey key)
|
boolean |
JobStoreSupport.removeTrigger(TriggerKey triggerKey)
Remove (delete) the with the
given name. |
boolean |
JobStoreSupport.removeTriggers(List<TriggerKey> triggerKeys)
|
protected boolean |
JobStoreSupport.replaceTrigger(Connection conn,
TriggerKey key,
org.quartz.spi.OperableTrigger newTrigger)
|
boolean |
JobStoreSupport.replaceTrigger(TriggerKey triggerKey,
org.quartz.spi.OperableTrigger newTrigger)
|
void |
JobStoreSupport.resumeAll()
Resume (un-pause) all triggers - equivalent of calling resumeTriggerGroup(group)
on every group. |
void |
JobStoreSupport.resumeAll(Connection conn)
protected |
void |
JobStoreSupport.resumeJob(JobKey jobKey)
Resume (un-pause) the with the
given name. |
Set<String> |
JobStoreSupport.resumeJobs(GroupMatcher<JobKey> matcher)
Resume (un-pause) all of the in
the given group. |
void |
JobStoreSupport.resumeTrigger(Connection conn,
TriggerKey key)
Resume (un-pause) the with the
given name. |
void |
JobStoreSupport.resumeTrigger(TriggerKey triggerKey)
Resume (un-pause) the with the
given name. |
Set<String> |
JobStoreSupport.resumeTriggerGroup(Connection conn,
GroupMatcher<TriggerKey> matcher)
Resume (un-pause) all of the
matching the given groupMatcher. |
Set<String> |
JobStoreSupport.resumeTriggers(GroupMatcher<TriggerKey> matcher)
Resume (un-pause) all of the
matching the given groupMatcher. |
protected Calendar |
JobStoreSupport.retrieveCalendar(Connection conn,
String calName)
|
Calendar |
JobStoreSupport.retrieveCalendar(String calName)
Retrieve the given . |
protected JobDetail |
JobStoreSupport.retrieveJob(Connection conn,
JobKey key)
|
JobDetail |
JobStoreSupport.retrieveJob(JobKey jobKey)
Retrieve the for the given
. |
protected org.quartz.spi.OperableTrigger |
JobStoreSupport.retrieveTrigger(Connection conn,
TriggerKey key)
|
org.quartz.spi.OperableTrigger |
JobStoreSupport.retrieveTrigger(TriggerKey triggerKey)
Retrieve the given . |
org.quartz.spi.OperableTrigger |
StdJDBCDelegate.selectTrigger(Connection conn,
TriggerKey triggerKey)
Select a trigger. |
org.quartz.spi.OperableTrigger |
DriverDelegate.selectTrigger(Connection conn,
TriggerKey triggerKey)
Select a trigger. |
List<org.quartz.spi.OperableTrigger> |
StdJDBCDelegate.selectTriggersForCalendar(Connection conn,
String calName)
|
List<org.quartz.spi.OperableTrigger> |
DriverDelegate.selectTriggersForCalendar(Connection conn,
String calName)
Select the triggers for a calendar |
List<org.quartz.spi.OperableTrigger> |
StdJDBCDelegate.selectTriggersForJob(Connection conn,
JobKey jobKey)
Select the triggers for a job |
List<org.quartz.spi.OperableTrigger> |
DriverDelegate.selectTriggersForJob(Connection conn,
JobKey jobKey)
Select the triggers for a job |
static void |
Util.setBeanProps(Object obj,
String[] propNames,
Object[] propValues)
|
protected void |
JobStoreSupport.storeCalendar(Connection conn,
String calName,
Calendar calendar,
boolean replaceExisting,
boolean updateTriggers)
|
void |
JobStoreSupport.storeCalendar(String calName,
Calendar calendar,
boolean replaceExisting,
boolean updateTriggers)
Store the given . |
protected void |
JobStoreSupport.storeJob(Connection conn,
JobDetail newJob,
boolean replaceExisting)
Insert or update a job. |
void |
JobStoreSupport.storeJob(JobDetail newJob,
boolean replaceExisting)
Store the given . |
void |
JobStoreSupport.storeJobAndTrigger(JobDetail newJob,
org.quartz.spi.OperableTrigger newTrigger)
Store the given and . |
void |
JobStoreSupport.storeJobsAndTriggers(Map<JobDetail,List<Trigger>> triggersAndJobs,
boolean replace)
|
protected void |
JobStoreSupport.storeTrigger(Connection conn,
org.quartz.spi.OperableTrigger newTrigger,
JobDetail job,
boolean replaceExisting,
String state,
boolean forceState,
boolean recovering)
Insert or update a trigger. |
void |
JobStoreSupport.storeTrigger(org.quartz.spi.OperableTrigger newTrigger,
boolean replaceExisting)
Store the given . |
protected void |
JobStoreSupport.triggeredJobComplete(Connection conn,
org.quartz.spi.OperableTrigger trigger,
JobDetail jobDetail,
Trigger.CompletedExecutionInstruction triggerInstCode)
|
void |
JobStoreSupport.triggeredJobComplete(org.quartz.spi.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 boolean |
JobStoreSupport.triggerExists(Connection conn,
TriggerKey key)
Check existence of a given trigger. |
protected org.quartz.spi.TriggerFiredBundle |
JobStoreSupport.triggerFired(Connection conn,
org.quartz.spi.OperableTrigger trigger)
|
List<org.quartz.spi.TriggerFiredResult> |
JobStoreSupport.triggersFired(List<org.quartz.spi.OperableTrigger> triggers)
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,
TriggerKey triggerKey,
String newStateIfNotComplete,
boolean forceState)
|
Uses of JobPersistenceException in org.quartz.locality |
---|
Subclasses of JobPersistenceException in org.quartz.locality | |
---|---|
class |
LocalityException
Exception thrown when some Constraint cannot be handled |
Uses of JobPersistenceException in org.quartz.simpl |
---|
Methods in org.quartz.simpl that throw JobPersistenceException | |
---|---|
void |
RAMJobStore.clearAllSchedulingData()
Clear (delete!) all scheduling data - all Job s, Trigger s
Calendar s. |
Set<String> |
RAMJobStore.getPausedTriggerGroups()
|
Trigger.TriggerState |
RAMJobStore.getTriggerState(TriggerKey triggerKey)
Get the current state of the identified . |
boolean |
RAMJobStore.removeCalendar(String calName)
Remove (delete) the with the
given name. |
boolean |
RAMJobStore.removeJobs(List<JobKey> jobKeys)
|
boolean |
RAMJobStore.removeTriggers(List<TriggerKey> triggerKeys)
|
boolean |
RAMJobStore.replaceTrigger(TriggerKey triggerKey,
org.quartz.spi.OperableTrigger newTrigger)
|
void |
RAMJobStore.storeJobAndTrigger(JobDetail newJob,
org.quartz.spi.OperableTrigger newTrigger)
Store the given and . |
void |
RAMJobStore.storeJobsAndTriggers(Map<JobDetail,List<Trigger>> triggersAndJobs,
boolean replace)
|
void |
RAMJobStore.storeTrigger(org.quartz.spi.OperableTrigger newTrigger,
boolean replaceExisting)
Store the given . |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |