org.quartz.simpl
Class RAMJobStore

java.lang.Object
  extended by org.quartz.simpl.RAMJobStore
All Implemented Interfaces:
org.quartz.spi.JobStore

public class RAMJobStore
extends Object
implements org.quartz.spi.JobStore

This class implements a JobStore that utilizes RAM as its storage device.

As you should know, the ramification of this is that access is extrememly fast, but the data is completely volatile - therefore this JobStore should not be used if true persistence between program shutdowns is required.

Author:
James House, Sharada Jambula, Eric Mueller

Field Summary
protected  HashSet<JobKey> blockedJobs
           
protected  HashMap<String,Calendar> calendarsByName
           
protected  HashMap<String,HashMap<JobKey,org.quartz.simpl.JobWrapper>> jobsByGroup
           
protected  HashMap<JobKey,org.quartz.simpl.JobWrapper> jobsByKey
           
protected  Object lock
           
protected  long misfireThreshold
           
protected  HashSet<String> pausedJobGroups
           
protected  HashSet<String> pausedTriggerGroups
           
protected  org.quartz.spi.SchedulerSignaler signaler
           
protected  TreeSet<org.quartz.simpl.TriggerWrapper> timeTriggers
           
protected  ArrayList<org.quartz.simpl.TriggerWrapper> triggers
           
protected  HashMap<String,HashMap<TriggerKey,org.quartz.simpl.TriggerWrapper>> triggersByGroup
           
protected  HashMap<TriggerKey,org.quartz.simpl.TriggerWrapper> triggersByKey
           
 
Constructor Summary
RAMJobStore()
           Create a new RAMJobStore.
 
Method Summary
 List<org.quartz.spi.OperableTrigger> 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.
protected  boolean applyMisfire(org.quartz.simpl.TriggerWrapper tw)
           
 boolean checkExists(JobKey jobKey)
          Determine whether a Job with the given identifier already exists within the scheduler.
 boolean checkExists(TriggerKey triggerKey)
          Determine whether a Trigger with the given identifier already exists within the scheduler.
 void clearAllSchedulingData()
          Clear (delete!) all scheduling data - all Jobs, Triggers Calendars.
 List<String> getCalendarNames()
           Get the names of all of the Calendar s in the JobStore.
 long getEstimatedTimeToReleaseAndAcquireTrigger()
           
protected  String getFiredTriggerRecordId()
           
 List<String> getJobGroupNames()
           Get the names of all of the Job groups.
 Set<JobKey> getJobKeys(GroupMatcher<JobKey> matcher)
           Get the names of all of the Job s that match the given groupMatcher.
protected  org.slf4j.Logger getLog()
           
 long getMisfireThreshold()
           
 int getNumberOfCalendars()
           Get the number of Calendar s that are stored in the JobsStore.
 int getNumberOfJobs()
           Get the number of JobDetail s that are stored in the JobsStore.
 int getNumberOfTriggers()
           Get the number of Trigger s that are stored in the JobsStore.
 Set<String> getPausedTriggerGroups()
           
 List<String> getTriggerGroupNames()
           Get the names of all of the Trigger groups.
 Set<TriggerKey> getTriggerKeys(GroupMatcher<TriggerKey> matcher)
           Get the names of all of the Trigger s that match the given groupMatcher.
 List<org.quartz.spi.OperableTrigger> getTriggersForJob(JobKey jobKey)
           Get all of the Triggers that are associated to the given Job.
 Trigger.TriggerState getTriggerState(TriggerKey triggerKey)
           Get the current state of the identified Trigger.
protected  ArrayList<org.quartz.simpl.TriggerWrapper> getTriggerWrappersForCalendar(String calName)
           
protected  ArrayList<org.quartz.simpl.TriggerWrapper> getTriggerWrappersForJob(JobKey jobKey)
           
 void initialize(org.quartz.spi.ClassLoadHelper loadHelper, org.quartz.spi.SchedulerSignaler schedSignaler)
           Called by the QuartzScheduler before the JobStore is used, in order to give the it a chance to initialize.
 boolean isClustered()
           
 void pauseAll()
           Pause all triggers - equivalent of calling pauseTriggerGroup(group) on every group.
 void pauseJob(JobKey jobKey)
           Pause the JobDetail with the given name - by pausing all of its current Triggers.
 List<String> pauseJobs(GroupMatcher<JobKey> matcher)
           Pause all of the JobDetails in the given group - by pausing all of their Triggers.
 void pauseTrigger(TriggerKey triggerKey)
           Pause the Trigger with the given name.
 List<String> pauseTriggers(GroupMatcher<TriggerKey> matcher)
           Pause all of the known Triggers matching.
protected  String peekTriggers()
           
 void 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).
 boolean removeCalendar(String calName)
           Remove (delete) the Calendar with the given name.
 boolean removeJob(JobKey jobKey)
           Remove (delete) the Job with the given name, and any Trigger s that reference it.
 boolean removeJobs(List<JobKey> jobKeys)
           
 boolean removeTrigger(TriggerKey triggerKey)
           Remove (delete) the Trigger with the given name.
 boolean removeTriggers(List<TriggerKey> triggerKeys)
           
 boolean replaceTrigger(TriggerKey triggerKey, org.quartz.spi.OperableTrigger newTrigger)
           
 void resumeAll()
           Resume (un-pause) all triggers - equivalent of calling resumeTriggerGroup(group) on every group.
 void resumeJob(JobKey jobKey)
           Resume (un-pause) the JobDetail with the given name.
 Collection<String> resumeJobs(GroupMatcher<JobKey> matcher)
           Resume (un-pause) all of the JobDetails in the given group.
 void resumeTrigger(TriggerKey triggerKey)
           Resume (un-pause) the Trigger with the given key.
 List<String> resumeTriggers(GroupMatcher<TriggerKey> matcher)
           Resume (un-pause) all of the Triggers in the given group.
 Calendar retrieveCalendar(String calName)
           Retrieve the given Trigger.
 JobDetail retrieveJob(JobKey jobKey)
           Retrieve the JobDetail for the given Job.
 org.quartz.spi.OperableTrigger retrieveTrigger(TriggerKey triggerKey)
           Retrieve the given Trigger.
 void schedulerPaused()
           
 void schedulerResumed()
           
 void schedulerStarted()
           
protected  void setAllTriggersOfJobToState(JobKey jobKey, int state)
           
 void setInstanceId(String schedInstId)
           
 void setInstanceName(String schedName)
           
 void setMisfireThreshold(long misfireThreshold)
          The number of milliseconds by which a trigger must have missed its next-fire-time, in order for it to be considered "misfired" and thus have its misfire instruction applied.
 void setThreadPoolSize(int poolSize)
           
 void shutdown()
           Called by the QuartzScheduler to inform the JobStore that it should free up all of it's resources because the scheduler is shutting down.
 void storeCalendar(String name, Calendar calendar, boolean replaceExisting, boolean updateTriggers)
           Store the given Calendar.
 void storeJob(JobDetail newJob, boolean replaceExisting)
           Store the given Job.
 void storeJobAndTrigger(JobDetail newJob, org.quartz.spi.OperableTrigger newTrigger)
           Store the given JobDetail and Trigger.
 void storeJobsAndTriggers(Map<JobDetail,List<Trigger>> triggersAndJobs, boolean replace)
           
 void storeTrigger(org.quartz.spi.OperableTrigger newTrigger, boolean replaceExisting)
           Store the given Trigger.
 boolean supportsPersistence()
           
 void 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 JobDataMap in the given JobDetail should be updated if the Job is stateful.
 List<org.quartz.spi.TriggerFiredResult> triggersFired(List<org.quartz.spi.OperableTrigger> firedTriggers)
           Inform the JobStore that the scheduler is now firing the given Trigger (executing its associated Job), that it had previously acquired (reserved).
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

jobsByKey

protected HashMap<JobKey,org.quartz.simpl.JobWrapper> jobsByKey

triggersByKey

protected HashMap<TriggerKey,org.quartz.simpl.TriggerWrapper> triggersByKey

jobsByGroup

protected HashMap<String,HashMap<JobKey,org.quartz.simpl.JobWrapper>> jobsByGroup

triggersByGroup

protected HashMap<String,HashMap<TriggerKey,org.quartz.simpl.TriggerWrapper>> triggersByGroup

timeTriggers

protected TreeSet<org.quartz.simpl.TriggerWrapper> timeTriggers

calendarsByName

protected HashMap<String,Calendar> calendarsByName

triggers

protected ArrayList<org.quartz.simpl.TriggerWrapper> triggers

lock

protected final Object lock

pausedTriggerGroups

protected HashSet<String> pausedTriggerGroups

pausedJobGroups

protected HashSet<String> pausedJobGroups

blockedJobs

protected HashSet<JobKey> blockedJobs

misfireThreshold

protected long misfireThreshold

signaler

protected org.quartz.spi.SchedulerSignaler signaler
Constructor Detail

RAMJobStore

public RAMJobStore()

Create a new RAMJobStore.

Method Detail

getLog

protected org.slf4j.Logger getLog()

initialize

public void initialize(org.quartz.spi.ClassLoadHelper loadHelper,
                       org.quartz.spi.SchedulerSignaler schedSignaler)

Called by the QuartzScheduler before the JobStore is used, in order to give the it a chance to initialize.

Specified by:
initialize in interface org.quartz.spi.JobStore

schedulerStarted

public void schedulerStarted()
Specified by:
schedulerStarted in interface org.quartz.spi.JobStore

schedulerPaused

public void schedulerPaused()
Specified by:
schedulerPaused in interface org.quartz.spi.JobStore

schedulerResumed

public void schedulerResumed()
Specified by:
schedulerResumed in interface org.quartz.spi.JobStore

getMisfireThreshold

public long getMisfireThreshold()

setMisfireThreshold

public void setMisfireThreshold(long misfireThreshold)
The number of milliseconds by which a trigger must have missed its next-fire-time, in order for it to be considered "misfired" and thus have its misfire instruction applied.

Parameters:
misfireThreshold -

shutdown

public void shutdown()

Called by the QuartzScheduler to inform the JobStore that it should free up all of it's resources because the scheduler is shutting down.

Specified by:
shutdown in interface org.quartz.spi.JobStore

supportsPersistence

public boolean supportsPersistence()
Specified by:
supportsPersistence in interface org.quartz.spi.JobStore

clearAllSchedulingData

public void clearAllSchedulingData()
                            throws JobPersistenceException
Clear (delete!) all scheduling data - all Jobs, Triggers Calendars.

Specified by:
clearAllSchedulingData in interface org.quartz.spi.JobStore
Throws:
JobPersistenceException

storeJobAndTrigger

public void storeJobAndTrigger(JobDetail newJob,
                               org.quartz.spi.OperableTrigger newTrigger)
                        throws JobPersistenceException

Store the given JobDetail and Trigger.

Specified by:
storeJobAndTrigger in interface org.quartz.spi.JobStore
Parameters:
newJob - The JobDetail to be stored.
newTrigger - The Trigger to be stored.
Throws:
ObjectAlreadyExistsException - if a Job with the same name/group already exists.
JobPersistenceException

storeJob

public void storeJob(JobDetail newJob,
                     boolean replaceExisting)
              throws ObjectAlreadyExistsException

Store the given Job.

Specified by:
storeJob in interface org.quartz.spi.JobStore
Parameters:
newJob - The Job to be stored.
replaceExisting - If true, any Job existing in the JobStore with the same name & group should be over-written.
Throws:
ObjectAlreadyExistsException - if a Job with the same name/group already exists, and replaceExisting is set to false.

removeJob

public boolean removeJob(JobKey jobKey)

Remove (delete) the Job with the given name, and any Trigger s that reference it.

Specified by:
removeJob in interface org.quartz.spi.JobStore
Returns:
true if a Job with the given name & group was found and removed from the store.

removeJobs

public boolean removeJobs(List<JobKey> jobKeys)
                   throws JobPersistenceException
Specified by:
removeJobs in interface org.quartz.spi.JobStore
Throws:
JobPersistenceException

removeTriggers

public boolean removeTriggers(List<TriggerKey> triggerKeys)
                       throws JobPersistenceException
Specified by:
removeTriggers in interface org.quartz.spi.JobStore
Throws:
JobPersistenceException

storeJobsAndTriggers

public void storeJobsAndTriggers(Map<JobDetail,List<Trigger>> triggersAndJobs,
                                 boolean replace)
                          throws ObjectAlreadyExistsException,
                                 JobPersistenceException
Specified by:
storeJobsAndTriggers in interface org.quartz.spi.JobStore
Throws:
ObjectAlreadyExistsException
JobPersistenceException

storeTrigger

public void storeTrigger(org.quartz.spi.OperableTrigger newTrigger,
                         boolean replaceExisting)
                  throws JobPersistenceException

Store the given Trigger.

Specified by:
storeTrigger in interface org.quartz.spi.JobStore
Parameters:
newTrigger - The Trigger to be stored.
replaceExisting - If true, any Trigger existing in the JobStore with the same name & group should be over-written.
Throws:
ObjectAlreadyExistsException - if a Trigger with the same name/group already exists, and replaceExisting is set to false.
JobPersistenceException
See Also:
#pauseTriggerGroup(SchedulingContext, String)

removeTrigger

public boolean removeTrigger(TriggerKey triggerKey)

Remove (delete) the Trigger with the given name.

Specified by:
removeTrigger in interface org.quartz.spi.JobStore
Returns:
true if a Trigger with the given name & group was found and removed from the store.

replaceTrigger

public boolean replaceTrigger(TriggerKey triggerKey,
                              org.quartz.spi.OperableTrigger newTrigger)
                       throws JobPersistenceException
Specified by:
replaceTrigger in interface org.quartz.spi.JobStore
Throws:
JobPersistenceException
See Also:
org.quartz.spi.JobStore#replaceTrigger(org.quartz.core.SchedulingContext, java.lang.String, java.lang.String, org.quartz.Trigger)

retrieveJob

public JobDetail retrieveJob(JobKey jobKey)

Retrieve the JobDetail for the given Job.

Specified by:
retrieveJob in interface org.quartz.spi.JobStore
Returns:
The desired Job, or null if there is no match.

retrieveTrigger

public org.quartz.spi.OperableTrigger retrieveTrigger(TriggerKey triggerKey)

Retrieve the given Trigger.

Specified by:
retrieveTrigger in interface org.quartz.spi.JobStore
Returns:
The desired Trigger, or null if there is no match.

checkExists

public boolean checkExists(JobKey jobKey)
Determine whether a Job with the given identifier already exists within the scheduler.

Specified by:
checkExists in interface org.quartz.spi.JobStore
Parameters:
jobKey - the identifier to check for
Returns:
true if a Job exists with the given identifier
Throws:
SchedulerException

checkExists

public boolean checkExists(TriggerKey triggerKey)
Determine whether a Trigger with the given identifier already exists within the scheduler.

Specified by:
checkExists in interface org.quartz.spi.JobStore
Parameters:
triggerKey - the identifier to check for
Returns:
true if a Trigger exists with the given identifier
Throws:
SchedulerException

getTriggerState

public Trigger.TriggerState getTriggerState(TriggerKey triggerKey)
                                     throws JobPersistenceException

Get the current state of the identified Trigger.

Specified by:
getTriggerState in interface org.quartz.spi.JobStore
Throws:
JobPersistenceException
See Also:
Trigger#NORMAL, Trigger#PAUSED, Trigger#COMPLETE, Trigger#ERROR, Trigger#BLOCKED, Trigger#NONE

storeCalendar

public void storeCalendar(String name,
                          Calendar calendar,
                          boolean replaceExisting,
                          boolean updateTriggers)
                   throws ObjectAlreadyExistsException

Store the given Calendar.

Specified by:
storeCalendar in interface org.quartz.spi.JobStore
Parameters:
calendar - The Calendar to be stored.
replaceExisting - If true, any Calendar existing in the JobStore with the same name & group should be over-written.
updateTriggers - If true, any Triggers existing in the JobStore that reference an existing Calendar with the same name with have their next fire time re-computed with the new Calendar.
Throws:
ObjectAlreadyExistsException - if a Calendar with the same name already exists, and replaceExisting is set to false.

removeCalendar

public boolean removeCalendar(String calName)
                       throws JobPersistenceException

Remove (delete) the Calendar with the given name.

If removal of the Calendar would result in Triggers pointing to non-existent calendars, then a JobPersistenceException will be thrown.

*

Specified by:
removeCalendar in interface org.quartz.spi.JobStore
Parameters:
calName - The name of the Calendar to be removed.
Returns:
true if a Calendar with the given name was found and removed from the store.
Throws:
JobPersistenceException

retrieveCalendar

public Calendar retrieveCalendar(String calName)

Retrieve the given Trigger.

Specified by:
retrieveCalendar in interface org.quartz.spi.JobStore
Parameters:
calName - The name of the Calendar to be retrieved.
Returns:
The desired Calendar, or null if there is no match.

getNumberOfJobs

public int getNumberOfJobs()

Get the number of JobDetail s that are stored in the JobsStore.

Specified by:
getNumberOfJobs in interface org.quartz.spi.JobStore

getNumberOfTriggers

public int getNumberOfTriggers()

Get the number of Trigger s that are stored in the JobsStore.

Specified by:
getNumberOfTriggers in interface org.quartz.spi.JobStore

getNumberOfCalendars

public int getNumberOfCalendars()

Get the number of Calendar s that are stored in the JobsStore.

Specified by:
getNumberOfCalendars in interface org.quartz.spi.JobStore

getJobKeys

public Set<JobKey> getJobKeys(GroupMatcher<JobKey> matcher)

Get the names of all of the Job s that match the given groupMatcher.

Specified by:
getJobKeys in interface org.quartz.spi.JobStore

getCalendarNames

public List<String> getCalendarNames()

Get the names of all of the Calendar s in the JobStore.

If there are no Calendars in the given group name, the result should be a zero-length array (not null).

Specified by:
getCalendarNames in interface org.quartz.spi.JobStore

getTriggerKeys

public Set<TriggerKey> getTriggerKeys(GroupMatcher<TriggerKey> matcher)

Get the names of all of the Trigger s that match the given groupMatcher.

Specified by:
getTriggerKeys in interface org.quartz.spi.JobStore

getJobGroupNames

public List<String> getJobGroupNames()

Get the names of all of the Job groups.

Specified by:
getJobGroupNames in interface org.quartz.spi.JobStore

getTriggerGroupNames

public List<String> getTriggerGroupNames()

Get the names of all of the Trigger groups.

Specified by:
getTriggerGroupNames in interface org.quartz.spi.JobStore

getTriggersForJob

public List<org.quartz.spi.OperableTrigger> getTriggersForJob(JobKey jobKey)

Get all of the Triggers that are associated to the given Job.

If there are no matches, a zero-length array should be returned.

Specified by:
getTriggersForJob in interface org.quartz.spi.JobStore

getTriggerWrappersForJob

protected ArrayList<org.quartz.simpl.TriggerWrapper> getTriggerWrappersForJob(JobKey jobKey)

getTriggerWrappersForCalendar

protected ArrayList<org.quartz.simpl.TriggerWrapper> getTriggerWrappersForCalendar(String calName)

pauseTrigger

public void pauseTrigger(TriggerKey triggerKey)

Pause the Trigger with the given name.

Specified by:
pauseTrigger in interface org.quartz.spi.JobStore

pauseTriggers

public List<String> pauseTriggers(GroupMatcher<TriggerKey> matcher)

Pause all of the known Triggers matching.

The JobStore should "remember" the groups paused, and impose the pause on any new triggers that are added to one of these groups while the group is paused.

Specified by:
pauseTriggers in interface org.quartz.spi.JobStore

pauseJob

public void pauseJob(JobKey jobKey)

Pause the JobDetail with the given name - by pausing all of its current Triggers.

Specified by:
pauseJob in interface org.quartz.spi.JobStore

pauseJobs

public List<String> pauseJobs(GroupMatcher<JobKey> matcher)

Pause all of the JobDetails in the given group - by pausing all of their Triggers.

The JobStore should "remember" that the group is paused, and impose the pause on any new jobs that are added to the group while the group is paused.

Specified by:
pauseJobs in interface org.quartz.spi.JobStore

resumeTrigger

public void resumeTrigger(TriggerKey triggerKey)

Resume (un-pause) the Trigger with the given key.

If the Trigger missed one or more fire-times, then the Trigger's misfire instruction will be applied.

Specified by:
resumeTrigger in interface org.quartz.spi.JobStore

resumeTriggers

public List<String> resumeTriggers(GroupMatcher<TriggerKey> matcher)

Resume (un-pause) all of the Triggers in the given group.

If any Trigger missed one or more fire-times, then the Trigger's misfire instruction will be applied.

Specified by:
resumeTriggers in interface org.quartz.spi.JobStore

resumeJob

public void resumeJob(JobKey jobKey)

Resume (un-pause) the JobDetail with the given name.

If any of the Job'sTrigger s missed one or more fire-times, then the Trigger's misfire instruction will be applied.

Specified by:
resumeJob in interface org.quartz.spi.JobStore

resumeJobs

public Collection<String> resumeJobs(GroupMatcher<JobKey> matcher)

Resume (un-pause) all of the JobDetails in the given group.

If any of the Job s had Trigger s that missed one or more fire-times, then the Trigger's misfire instruction will be applied.

Specified by:
resumeJobs in interface org.quartz.spi.JobStore

pauseAll

public void pauseAll()

Pause all triggers - equivalent of calling pauseTriggerGroup(group) on every group.

When resumeAll() is called (to un-pause), trigger misfire instructions WILL be applied.

Specified by:
pauseAll in interface org.quartz.spi.JobStore
See Also:
#resumeAll(SchedulingContext), #pauseTriggerGroup(SchedulingContext, String)

resumeAll

public void resumeAll()

Resume (un-pause) all triggers - equivalent of calling resumeTriggerGroup(group) on every group.

If any Trigger missed one or more fire-times, then the Trigger's misfire instruction will be applied.

Specified by:
resumeAll in interface org.quartz.spi.JobStore
See Also:
#pauseAll(SchedulingContext)

applyMisfire

protected boolean applyMisfire(org.quartz.simpl.TriggerWrapper tw)

getFiredTriggerRecordId

protected String getFiredTriggerRecordId()

acquireNextTriggers

public List<org.quartz.spi.OperableTrigger> 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.

Specified by:
acquireNextTriggers in interface org.quartz.spi.JobStore
See Also:
#releaseAcquiredTrigger(SchedulingContext, Trigger)

releaseAcquiredTrigger

public void 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).

Specified by:
releaseAcquiredTrigger in interface org.quartz.spi.JobStore

triggersFired

public List<org.quartz.spi.TriggerFiredResult> triggersFired(List<org.quartz.spi.OperableTrigger> firedTriggers)

Inform the JobStore that the scheduler is now firing the given Trigger (executing its associated Job), that it had previously acquired (reserved).

Specified by:
triggersFired in interface org.quartz.spi.JobStore

triggeredJobComplete

public void 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 JobDataMap in the given JobDetail should be updated if the Job is stateful.

Specified by:
triggeredJobComplete in interface org.quartz.spi.JobStore

setAllTriggersOfJobToState

protected void setAllTriggersOfJobToState(JobKey jobKey,
                                          int state)

peekTriggers

protected String peekTriggers()

getPausedTriggerGroups

public Set<String> getPausedTriggerGroups()
                                   throws JobPersistenceException
Specified by:
getPausedTriggerGroups in interface org.quartz.spi.JobStore
Throws:
JobPersistenceException
See Also:
org.quartz.spi.JobStore#getPausedTriggerGroups(org.quartz.core.SchedulingContext)

setInstanceId

public void setInstanceId(String schedInstId)
Specified by:
setInstanceId in interface org.quartz.spi.JobStore

setInstanceName

public void setInstanceName(String schedName)
Specified by:
setInstanceName in interface org.quartz.spi.JobStore

setThreadPoolSize

public void setThreadPoolSize(int poolSize)
Specified by:
setThreadPoolSize in interface org.quartz.spi.JobStore

getEstimatedTimeToReleaseAndAcquireTrigger

public long getEstimatedTimeToReleaseAndAcquireTrigger()
Specified by:
getEstimatedTimeToReleaseAndAcquireTrigger in interface org.quartz.spi.JobStore

isClustered

public boolean isClustered()
Specified by:
isClustered in interface org.quartz.spi.JobStore


Copyright 2001-2013, Terracotta, Inc.