com.atlassian.scheduler
Class OfBizJobStore

java.lang.Object
  extended by com.atlassian.scheduler.OfBizJobStore
All Implemented Interfaces:
org.quartz.spi.JobStore

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

This was taken from atlassian-scheduler and placed into its now rightful home of JIRA.

Since:
4.3

Field Summary
static String STATE_ACQUIRED
           
static String STATE_BLOCKED
           
static String STATE_COMPLETE
           
static String STATE_EXECUTING
           
static String STATE_WAITING
           
static String TTYPE_CRON
           
static String TTYPE_SIMPLE
           
 
Constructor Summary
OfBizJobStore()
           
 
Method Summary
 org.quartz.Trigger acquireNextTrigger(org.quartz.core.SchedulingContext ctxt, long noLaterThan)
           
 String[] getCalendarNames(org.quartz.core.SchedulingContext ctxt)
           
 String[] getJobGroupNames(org.quartz.core.SchedulingContext ctxt)
           
 String[] getJobNames(org.quartz.core.SchedulingContext ctxt, String groupName)
           
 int getNumberOfCalendars(org.quartz.core.SchedulingContext ctxt)
           
 int getNumberOfJobs(org.quartz.core.SchedulingContext ctxt)
           
 int getNumberOfTriggers(org.quartz.core.SchedulingContext ctxt)
           
 Set getPausedTriggerGroups(org.quartz.core.SchedulingContext ctxt)
           
 String[] getTriggerGroupNames(org.quartz.core.SchedulingContext ctxt)
           
 String[] getTriggerNames(org.quartz.core.SchedulingContext ctxt, String groupName)
           
 org.quartz.Trigger[] getTriggersAfterDate(org.quartz.core.SchedulingContext ctxt, Date fireAfterDate)
           
 org.quartz.Trigger[] getTriggersBeforeDate(org.quartz.core.SchedulingContext ctxt, Date fireBeforeDate)
           
 org.quartz.Trigger[] getTriggersDuringDateRange(org.quartz.core.SchedulingContext ctxt, Date fireAfterDate, Date fireBeforeDate)
           
 org.quartz.Trigger[] getTriggersForJob(org.quartz.core.SchedulingContext ctxt, String jobName, String groupName)
           
 int getTriggerState(org.quartz.core.SchedulingContext ctxt, String triggerName, String triggerGroup)
           
 void initialize(org.quartz.spi.ClassLoadHelper loadHelper, org.quartz.spi.SchedulerSignaler signaler)
           
 void pauseAll(org.quartz.core.SchedulingContext ctxt)
           
 void pauseJob(org.quartz.core.SchedulingContext ctxt, String jobName, String groupName)
           
 void pauseJobGroup(org.quartz.core.SchedulingContext ctxt, String groupName)
           
 void pauseTrigger(org.quartz.core.SchedulingContext ctxt, String triggerName, String groupName)
           
 void pauseTriggerGroup(org.quartz.core.SchedulingContext ctxt, String groupName)
           
 void releaseAcquiredTrigger(org.quartz.core.SchedulingContext ctxt, org.quartz.Trigger trigger)
           
 boolean removeCalendar(org.quartz.core.SchedulingContext ctxt, String calName)
           
 boolean removeJob(org.quartz.core.SchedulingContext ctxt, String jobName, String groupName)
           
 boolean removeTrigger(org.quartz.core.SchedulingContext ctxt, String triggerName, String groupName)
           
 boolean replaceTrigger(org.quartz.core.SchedulingContext ctxt, String triggerName, String groupName, org.quartz.Trigger newTrigger)
           
 void resumeAll(org.quartz.core.SchedulingContext ctxt)
           
 void resumeJob(org.quartz.core.SchedulingContext ctxt, String jobName, String groupName)
           
 void resumeJobGroup(org.quartz.core.SchedulingContext ctxt, String groupName)
           
 void resumeTrigger(org.quartz.core.SchedulingContext ctxt, String triggerName, String groupName)
           
 void resumeTriggerGroup(org.quartz.core.SchedulingContext ctxt, String groupName)
           
 org.quartz.Calendar retrieveCalendar(org.quartz.core.SchedulingContext ctxt, String calName)
           
 org.quartz.JobDetail retrieveJob(org.quartz.core.SchedulingContext ctxt, String jobName, String groupName)
           
 org.quartz.Trigger retrieveTrigger(org.quartz.core.SchedulingContext ctxt, String triggerName, String groupName)
           
 void schedulerStarted()
           
 void shutdown()
           
 void storeCalendar(org.quartz.core.SchedulingContext ctxt, String name, org.quartz.Calendar calendar)
           
 void storeCalendar(org.quartz.core.SchedulingContext ctxt, String name, org.quartz.Calendar calendar, boolean replaceExisting)
           
 void storeCalendar(org.quartz.core.SchedulingContext ctxt, String name, org.quartz.Calendar calendar, boolean replaceExisting, boolean updateTriggers)
           
 void storeJob(org.quartz.core.SchedulingContext ctxt, org.quartz.JobDetail newJob)
           
 void storeJob(org.quartz.core.SchedulingContext ctxt, org.quartz.JobDetail newJob, boolean replaceExisting)
           
 void storeJobAndTrigger(org.quartz.core.SchedulingContext ctxt, org.quartz.JobDetail newJob, org.quartz.Trigger newTrigger)
           
 void storeTrigger(org.quartz.core.SchedulingContext ctxt, org.quartz.Trigger newTrigger)
           
 void storeTrigger(org.quartz.core.SchedulingContext ctxt, org.quartz.Trigger newTrigger, boolean replaceExisting)
           
 boolean supportsPersistence()
           
 void triggeredJobComplete(org.quartz.core.SchedulingContext ctxt, org.quartz.Trigger trigger, org.quartz.JobDetail jobDetail, int triggerInstCode)
           
 org.quartz.spi.TriggerFiredBundle triggerFired(org.quartz.core.SchedulingContext ctxt, org.quartz.Trigger trigger)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

STATE_WAITING

public static final String STATE_WAITING
See Also:
Constant Field Values

STATE_ACQUIRED

public static final String STATE_ACQUIRED
See Also:
Constant Field Values

STATE_EXECUTING

public static final String STATE_EXECUTING
See Also:
Constant Field Values

STATE_COMPLETE

public static final String STATE_COMPLETE
See Also:
Constant Field Values

STATE_BLOCKED

public static final String STATE_BLOCKED
See Also:
Constant Field Values

TTYPE_SIMPLE

public static final String TTYPE_SIMPLE
See Also:
Constant Field Values

TTYPE_CRON

public static final String TTYPE_CRON
See Also:
Constant Field Values
Constructor Detail

OfBizJobStore

public OfBizJobStore()
Method Detail

initialize

public void initialize(org.quartz.spi.ClassLoadHelper loadHelper,
                       org.quartz.spi.SchedulerSignaler signaler)
                throws org.quartz.SchedulerConfigException
Specified by:
initialize in interface org.quartz.spi.JobStore
Throws:
org.quartz.SchedulerConfigException

schedulerStarted

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

shutdown

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

supportsPersistence

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

storeJobAndTrigger

public void storeJobAndTrigger(org.quartz.core.SchedulingContext ctxt,
                               org.quartz.JobDetail newJob,
                               org.quartz.Trigger newTrigger)
                        throws org.quartz.ObjectAlreadyExistsException,
                               org.quartz.JobPersistenceException
Specified by:
storeJobAndTrigger in interface org.quartz.spi.JobStore
Throws:
org.quartz.ObjectAlreadyExistsException
org.quartz.JobPersistenceException

storeJob

public void storeJob(org.quartz.core.SchedulingContext ctxt,
                     org.quartz.JobDetail newJob)
              throws org.quartz.ObjectAlreadyExistsException,
                     org.quartz.JobPersistenceException
Throws:
org.quartz.ObjectAlreadyExistsException
org.quartz.JobPersistenceException

storeJob

public void storeJob(org.quartz.core.SchedulingContext ctxt,
                     org.quartz.JobDetail newJob,
                     boolean replaceExisting)
              throws org.quartz.ObjectAlreadyExistsException,
                     org.quartz.JobPersistenceException
Specified by:
storeJob in interface org.quartz.spi.JobStore
Throws:
org.quartz.ObjectAlreadyExistsException
org.quartz.JobPersistenceException

removeJob

public boolean removeJob(org.quartz.core.SchedulingContext ctxt,
                         String jobName,
                         String groupName)
                  throws org.quartz.JobPersistenceException
Specified by:
removeJob in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

retrieveJob

public org.quartz.JobDetail retrieveJob(org.quartz.core.SchedulingContext ctxt,
                                        String jobName,
                                        String groupName)
                                 throws org.quartz.JobPersistenceException
Specified by:
retrieveJob in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

storeTrigger

public void storeTrigger(org.quartz.core.SchedulingContext ctxt,
                         org.quartz.Trigger newTrigger)
                  throws org.quartz.ObjectAlreadyExistsException,
                         org.quartz.JobPersistenceException
Throws:
org.quartz.ObjectAlreadyExistsException
org.quartz.JobPersistenceException

storeTrigger

public void storeTrigger(org.quartz.core.SchedulingContext ctxt,
                         org.quartz.Trigger newTrigger,
                         boolean replaceExisting)
                  throws org.quartz.ObjectAlreadyExistsException,
                         org.quartz.JobPersistenceException
Specified by:
storeTrigger in interface org.quartz.spi.JobStore
Throws:
org.quartz.ObjectAlreadyExistsException
org.quartz.JobPersistenceException

removeTrigger

public boolean removeTrigger(org.quartz.core.SchedulingContext ctxt,
                             String triggerName,
                             String groupName)
                      throws org.quartz.JobPersistenceException
Specified by:
removeTrigger in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

retrieveTrigger

public org.quartz.Trigger retrieveTrigger(org.quartz.core.SchedulingContext ctxt,
                                          String triggerName,
                                          String groupName)
                                   throws org.quartz.JobPersistenceException
Specified by:
retrieveTrigger in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

replaceTrigger

public boolean replaceTrigger(org.quartz.core.SchedulingContext ctxt,
                              String triggerName,
                              String groupName,
                              org.quartz.Trigger newTrigger)
                       throws org.quartz.JobPersistenceException
Specified by:
replaceTrigger in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

getTriggerState

public int getTriggerState(org.quartz.core.SchedulingContext ctxt,
                           String triggerName,
                           String triggerGroup)
                    throws org.quartz.JobPersistenceException
Specified by:
getTriggerState in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

storeCalendar

public void storeCalendar(org.quartz.core.SchedulingContext ctxt,
                          String name,
                          org.quartz.Calendar calendar)
                   throws org.quartz.ObjectAlreadyExistsException,
                          org.quartz.JobPersistenceException
Throws:
org.quartz.ObjectAlreadyExistsException
org.quartz.JobPersistenceException

storeCalendar

public void storeCalendar(org.quartz.core.SchedulingContext ctxt,
                          String name,
                          org.quartz.Calendar calendar,
                          boolean replaceExisting)
                   throws org.quartz.ObjectAlreadyExistsException,
                          org.quartz.JobPersistenceException
Throws:
org.quartz.ObjectAlreadyExistsException
org.quartz.JobPersistenceException

storeCalendar

public void storeCalendar(org.quartz.core.SchedulingContext ctxt,
                          String name,
                          org.quartz.Calendar calendar,
                          boolean replaceExisting,
                          boolean updateTriggers)
                   throws org.quartz.ObjectAlreadyExistsException,
                          org.quartz.JobPersistenceException
Specified by:
storeCalendar in interface org.quartz.spi.JobStore
Throws:
org.quartz.ObjectAlreadyExistsException
org.quartz.JobPersistenceException

removeCalendar

public boolean removeCalendar(org.quartz.core.SchedulingContext ctxt,
                              String calName)
                       throws org.quartz.JobPersistenceException
Specified by:
removeCalendar in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

retrieveCalendar

public org.quartz.Calendar retrieveCalendar(org.quartz.core.SchedulingContext ctxt,
                                            String calName)
                                     throws org.quartz.JobPersistenceException
Specified by:
retrieveCalendar in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

getNumberOfJobs

public int getNumberOfJobs(org.quartz.core.SchedulingContext ctxt)
                    throws org.quartz.JobPersistenceException
Specified by:
getNumberOfJobs in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

getNumberOfTriggers

public int getNumberOfTriggers(org.quartz.core.SchedulingContext ctxt)
                        throws org.quartz.JobPersistenceException
Specified by:
getNumberOfTriggers in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

getNumberOfCalendars

public int getNumberOfCalendars(org.quartz.core.SchedulingContext ctxt)
                         throws org.quartz.JobPersistenceException
Specified by:
getNumberOfCalendars in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

getJobNames

public String[] getJobNames(org.quartz.core.SchedulingContext ctxt,
                            String groupName)
                     throws org.quartz.JobPersistenceException
Specified by:
getJobNames in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

getTriggerNames

public String[] getTriggerNames(org.quartz.core.SchedulingContext ctxt,
                                String groupName)
                         throws org.quartz.JobPersistenceException
Specified by:
getTriggerNames in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

getJobGroupNames

public String[] getJobGroupNames(org.quartz.core.SchedulingContext ctxt)
                          throws org.quartz.JobPersistenceException
Specified by:
getJobGroupNames in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

getTriggerGroupNames

public String[] getTriggerGroupNames(org.quartz.core.SchedulingContext ctxt)
                              throws org.quartz.JobPersistenceException
Specified by:
getTriggerGroupNames in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

getCalendarNames

public String[] getCalendarNames(org.quartz.core.SchedulingContext ctxt)
                          throws org.quartz.JobPersistenceException
Specified by:
getCalendarNames in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

getTriggersBeforeDate

public org.quartz.Trigger[] getTriggersBeforeDate(org.quartz.core.SchedulingContext ctxt,
                                                  Date fireBeforeDate)
                                           throws org.quartz.JobPersistenceException
Throws:
org.quartz.JobPersistenceException

getTriggersAfterDate

public org.quartz.Trigger[] getTriggersAfterDate(org.quartz.core.SchedulingContext ctxt,
                                                 Date fireAfterDate)
                                          throws org.quartz.JobPersistenceException
Throws:
org.quartz.JobPersistenceException

getTriggersDuringDateRange

public org.quartz.Trigger[] getTriggersDuringDateRange(org.quartz.core.SchedulingContext ctxt,
                                                       Date fireAfterDate,
                                                       Date fireBeforeDate)
                                                throws org.quartz.JobPersistenceException
Throws:
org.quartz.JobPersistenceException

getTriggersForJob

public org.quartz.Trigger[] getTriggersForJob(org.quartz.core.SchedulingContext ctxt,
                                              String jobName,
                                              String groupName)
                                       throws org.quartz.JobPersistenceException
Specified by:
getTriggersForJob in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

pauseTrigger

public void pauseTrigger(org.quartz.core.SchedulingContext ctxt,
                         String triggerName,
                         String groupName)
                  throws org.quartz.JobPersistenceException
Specified by:
pauseTrigger in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

pauseTriggerGroup

public void pauseTriggerGroup(org.quartz.core.SchedulingContext ctxt,
                              String groupName)
                       throws org.quartz.JobPersistenceException
Specified by:
pauseTriggerGroup in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

getPausedTriggerGroups

public Set getPausedTriggerGroups(org.quartz.core.SchedulingContext ctxt)
                           throws org.quartz.JobPersistenceException
Specified by:
getPausedTriggerGroups in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

pauseJob

public void pauseJob(org.quartz.core.SchedulingContext ctxt,
                     String jobName,
                     String groupName)
              throws org.quartz.JobPersistenceException
Specified by:
pauseJob in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

pauseJobGroup

public void pauseJobGroup(org.quartz.core.SchedulingContext ctxt,
                          String groupName)
                   throws org.quartz.JobPersistenceException
Specified by:
pauseJobGroup in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

resumeTrigger

public void resumeTrigger(org.quartz.core.SchedulingContext ctxt,
                          String triggerName,
                          String groupName)
                   throws org.quartz.JobPersistenceException
Specified by:
resumeTrigger in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

resumeTriggerGroup

public void resumeTriggerGroup(org.quartz.core.SchedulingContext ctxt,
                               String groupName)
                        throws org.quartz.JobPersistenceException
Specified by:
resumeTriggerGroup in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

resumeJob

public void resumeJob(org.quartz.core.SchedulingContext ctxt,
                      String jobName,
                      String groupName)
               throws org.quartz.JobPersistenceException
Specified by:
resumeJob in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

resumeJobGroup

public void resumeJobGroup(org.quartz.core.SchedulingContext ctxt,
                           String groupName)
                    throws org.quartz.JobPersistenceException
Specified by:
resumeJobGroup in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

pauseAll

public void pauseAll(org.quartz.core.SchedulingContext ctxt)
              throws org.quartz.JobPersistenceException
Specified by:
pauseAll in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

resumeAll

public void resumeAll(org.quartz.core.SchedulingContext ctxt)
               throws org.quartz.JobPersistenceException
Specified by:
resumeAll in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

acquireNextTrigger

public org.quartz.Trigger acquireNextTrigger(org.quartz.core.SchedulingContext ctxt,
                                             long noLaterThan)
                                      throws org.quartz.JobPersistenceException
Specified by:
acquireNextTrigger in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

releaseAcquiredTrigger

public void releaseAcquiredTrigger(org.quartz.core.SchedulingContext ctxt,
                                   org.quartz.Trigger trigger)
                            throws org.quartz.JobPersistenceException
Specified by:
releaseAcquiredTrigger in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

triggerFired

public org.quartz.spi.TriggerFiredBundle triggerFired(org.quartz.core.SchedulingContext ctxt,
                                                      org.quartz.Trigger trigger)
                                               throws org.quartz.JobPersistenceException
Specified by:
triggerFired in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException

triggeredJobComplete

public void triggeredJobComplete(org.quartz.core.SchedulingContext ctxt,
                                 org.quartz.Trigger trigger,
                                 org.quartz.JobDetail jobDetail,
                                 int triggerInstCode)
                          throws org.quartz.JobPersistenceException
Specified by:
triggeredJobComplete in interface org.quartz.spi.JobStore
Throws:
org.quartz.JobPersistenceException


Copyright © 2002-2012 Atlassian. All Rights Reserved.