RAMJobStore (Quartz Parent POM 2.0.1 API)

From Quartz Java

previous page next page

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.quartz.simpl Class RAMJobStore

java.lang.Object
  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
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 signaler)


          
 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
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> triggers)


          
 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 signaler)


 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()
                      throws SchedulerException


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


Throws:
SchedulerException




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> triggers)


 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 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
















 Overview 
 Package 
  Class 
 Use 
 Tree 
 Deprecated 
 Index 
 Help 









 PREV CLASS 
 NEXT CLASS

FRAMES   
 NO FRAMES   
 





  SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD





Copyright 2001-2011, Terracotta, Inc.

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 `Job`s, `Trigger`s `Calendar`s.
`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`	`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 signaler)` 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`	`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> triggers)` 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`



  
  
    
      previous page
    

     start

    
       next page