org.quartz.impl.jdbcjobstore

Class QueueJobStore

java.lang.Object

org.quartz.impl.jdbcjobstore.JobStoreSupport

org.quartz.impl.jdbcjobstore.JobStoreCMT

org.quartz.impl.jdbcjobstore.QueueJobStore

All Implemented Interfaces:

org.quartz.impl.jdbcjobstore.Constants, org.quartz.spi.JobStore

public class QueueJobStore
extends org.quartz.impl.jdbcjobstore.JobStoreCMT

Subclass of Quartz's JobStoreCMT class which provides the following functionalities: - Delegates to a Spring-managed DataSource instead of Quartz-managed connection pool - Invokes jobs in the order they were scheduled. (Quartz invokes jobs based on the scheduled time, but if the scheduled time is missed it doesn't invoke the job in the order it was scheduled) Usage: 1. Define the following in application context class 2. Define data source bean Eg. 3. Define the following properties in scheduler bean quartzDataSource org.quartz.impl.jdbcjobstore.QueueJobStore org.quartz.impl.jdbcjobstore.oracle.OracleDelegate DAM_BIGJOB_

Version:

$Rev$

Author:

Rohini Raman Last updated by: $Author$

Nested Class Summary

Nested classes/interfaces inherited from class org.quartz.impl.jdbcjobstore.JobStoreSupport

org.quartz.impl.jdbcjobstore.JobStoreSupport.RecoverMisfiredJobsResult, org.quartz.impl.jdbcjobstore.JobStoreSupport.TransactionCallback, org.quartz.impl.jdbcjobstore.JobStoreSupport.VoidTransactionCallback

Field Summary

Fields

Modifier and Type	Field and Description
static String	RECOVERED_INTERRUPTED_JOB

Fields inherited from class org.quartz.impl.jdbcjobstore.JobStoreCMT

dontSetNonManagedTXConnectionAutoCommitFalse, nonManagedTxDsName, setTxIsolationLevelReadCommitted

Fields inherited from class org.quartz.impl.jdbcjobstore.JobStoreSupport

calendarCache, delegateClass, delegateClassName, dsName, firstCheckIn, instanceId, instanceName, lastCheckin, LOCK_CALENDAR_ACCESS, LOCK_JOB_ACCESS, LOCK_MISFIRE_ACCESS, LOCK_STATE_ACCESS, LOCK_TRIGGER_ACCESS, maxToRecoverAtATime, sigChangeForTxCompletion, tablePrefix, useProperties

Fields inherited from interface org.quartz.impl.jdbcjobstore.Constants

ALIAS_COL_NEXT_FIRE_TIME, ALL_GROUPS_PAUSED, COL_BLOB, COL_CALENDAR, COL_CALENDAR_NAME, COL_CHECKIN_INTERVAL, COL_CRON_EXPRESSION, COL_DESCRIPTION, COL_END_TIME, COL_ENTRY_ID, COL_ENTRY_STATE, COL_FIRED_TIME, COL_INSTANCE_NAME, COL_IS_DURABLE, COL_IS_STATEFUL, COL_IS_VOLATILE, COL_JOB_CLASS, COL_JOB_DATAMAP, COL_JOB_GROUP, COL_JOB_LISTENER, COL_JOB_NAME, COL_LAST_CHECKIN_TIME, COL_LOCK_NAME, COL_MISFIRE_INSTRUCTION, COL_NEXT_FIRE_TIME, COL_PREV_FIRE_TIME, COL_PRIORITY, COL_REPEAT_COUNT, COL_REPEAT_INTERVAL, COL_REQUESTS_RECOVERY, COL_START_TIME, COL_TIME_ZONE_ID, COL_TIMES_TRIGGERED, COL_TRIGGER_GROUP, COL_TRIGGER_LISTENER, COL_TRIGGER_NAME, COL_TRIGGER_STATE, COL_TRIGGER_TYPE, DEFAULT_TABLE_PREFIX, STATE_ACQUIRED, STATE_BLOCKED, STATE_COMPLETE, STATE_DELETED, STATE_ERROR, STATE_EXECUTING, STATE_MISFIRED, STATE_PAUSED, STATE_PAUSED_BLOCKED, STATE_WAITING, TABLE_BLOB_TRIGGERS, TABLE_CALENDARS, TABLE_CRON_TRIGGERS, TABLE_FIRED_TRIGGERS, TABLE_JOB_DETAILS, TABLE_JOB_LISTENERS, TABLE_LOCKS, TABLE_PAUSED_TRIGGERS, TABLE_SCHEDULER_STATE, TABLE_SIMPLE_TRIGGERS, TABLE_TRIGGER_LISTENERS, TABLE_TRIGGERS, TTYPE_BLOB, TTYPE_CRON, TTYPE_SIMPLE

Constructor Summary

Constructors

Constructor and Description
QueueJobStore()

Method Summary

Methods

Modifier and Type	Method and Description
protected long	getMisfireTime() return the misfire time to be 0 so that quartz gets the jobs in the next firing time order
void	initialize(org.quartz.spi.ClassLoadHelper loadHelper, org.quartz.spi.SchedulerSignaler signaler) Initializes Spring-managed connection pool instead of Quartz-managed connection pool The datasource name is injected from , the corresponding datasource bean and gov.nih.nci.ncicb.tcga.dcc.common.framework.SpringApplicationContext should be defined in spring application context file
protected void	recoverJobs(Connection conn) Recover any failed or misfired jobs and clean up the data store as appropriate.
protected boolean	updateCompletedTriggerToWaiting(Connection conn, String triggerName, String groupName) Update complete trigger next firing time to trigger start time

Methods inherited from class org.quartz.impl.jdbcjobstore.JobStoreCMT

executeInLock, getNonManagedTXConnection, getNonManagedTXDataSource, isDontSetNonManagedTXConnectionAutoCommitFalse, isTxIsolationLevelReadCommitted, setDontSetNonManagedTXConnectionAutoCommitFalse, setNonManagedTXDataSource, setTxIsolationLevelReadCommitted, shutdown

Methods inherited from class org.quartz.impl.jdbcjobstore.JobStoreSupport

acquireNextTrigger, acquireNextTrigger, calcFailedIfAfter, calendarExists, canUseProperties, checkBlockedState, cleanupConnection, cleanVolatileTriggerAndJobs, cleanVolatileTriggerAndJobs, clearAndGetSignalSchedulingChangeOnTxCompletion, closeConnection, clusterCheckIn, clusterRecover, commitConnection, doCheckin, doRecoverMisfires, executeInLock, executeInNonManagedTXLock, executeInNonManagedTXLock, executeWithoutLock, findFailedInstances, getAttributeRestoringConnection, getCalendarNames, getCalendarNames, getClassLoadHelper, getClusterCheckinInterval, getConnection, getDataSource, getDbRetryInterval, getDelegate, getDoubleCheckLockMisfireHandler, getDriverDelegateClass, getEstimatedTimeToReleaseAndAcquireTrigger, getFiredTriggerRecordId, getInstanceId, getInstanceName, getJobGroupNames, getJobGroupNames, getJobNames, getJobNames, getLockHandler, getLog, getMakeThreadsDaemons, getMaxMisfiresToHandleAtATime, getMisfireThreshold, getNumberOfCalendars, getNumberOfCalendars, getNumberOfJobs, getNumberOfJobs, getNumberOfTriggers, getNumberOfTriggers, getPausedTriggerGroups, getPausedTriggerGroups, getSelectWithLockSQL, getTablePrefix, getThreadExecutor, getTriggerGroupNames, getTriggerGroupNames, getTriggerNames, getTriggerNames, getTriggersForJob, getTriggersForJob, getTriggerState, getTriggerState, getUseDBLocks, isAcquireTriggersWithinLock, isClustered, isDontSetAutoCommitFalse, isLockOnInsert, isThreadsInheritInitializersClassLoadContext, isTxIsolationLevelSerializable, jobExists, logWarnIfNonZero, pauseAll, pauseAll, pauseJob, pauseJobGroup, pauseTrigger, pauseTrigger, pauseTriggerGroup, pauseTriggerGroup, recoverJobs, recoverMisfiredJobs, releaseAcquiredTrigger, releaseAcquiredTrigger, releaseLock, removeCalendar, removeCalendar, removeJob, removeJob, removeTrigger, removeTrigger, replaceTrigger, replaceTrigger, resumeAll, resumeAll, resumeJob, resumeJobGroup, resumeTrigger, resumeTrigger, resumeTriggerGroup, resumeTriggerGroup, retrieveCalendar, retrieveCalendar, retrieveJob, retrieveJob, retrieveTrigger, retrieveTrigger, retrieveTrigger, rollbackConnection, schedulerStarted, setAcquireTriggersWithinLock, setClusterCheckinInterval, setDataSource, setDbRetryInterval, setDontSetAutoCommitFalse, setDoubleCheckLockMisfireHandler, setDriverDelegateClass, setInstanceId, setInstanceName, setIsClustered, setLockHandler, setLockOnInsert, setMakeThreadsDaemons, setMaxMisfiresToHandleAtATime, setMisfireThreshold, setSelectWithLockSQL, setTablePrefix, setThreadExecutor, setThreadsInheritInitializersClassLoadContext, setTxIsolationLevelSerializable, setUseDBLocks, setUseProperties, signalSchedulingChangeImmediately, signalSchedulingChangeOnTxCompletion, storeCalendar, storeCalendar, storeJob, storeJob, storeJobAndTrigger, storeTrigger, storeTrigger, supportsPersistence, triggeredJobComplete, triggeredJobComplete, triggerExists, triggerFired, triggerFired, updateMisfiredTrigger

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

RECOVERED_INTERRUPTED_JOB

public static final String RECOVERED_INTERRUPTED_JOB

See Also:

Constant Field Values

Constructor Detail

QueueJobStore

public QueueJobStore()

Method Detail

initialize

public void initialize(org.quartz.spi.ClassLoadHelper loadHelper,
              org.quartz.spi.SchedulerSignaler signaler)
                throws org.quartz.SchedulerConfigException

Initializes Spring-managed connection pool instead of Quartz-managed connection pool The datasource name is injected from , the corresponding datasource bean and gov.nih.nci.ncicb.tcga.dcc.common.framework.SpringApplicationContext should be defined in spring application context file

Specified by:

initialize in interface org.quartz.spi.JobStore

Overrides:

initialize in class org.quartz.impl.jdbcjobstore.JobStoreCMT

Parameters:

loadHelper -

signaler -

Throws:

org.quartz.SchedulerConfigException

getMisfireTime

protected long getMisfireTime()

return the misfire time to be 0 so that quartz gets the jobs in the next firing time order

Overrides:

getMisfireTime in class org.quartz.impl.jdbcjobstore.JobStoreSupport

Returns:

recoverJobs

protected void recoverJobs(Connection conn)
                    throws org.quartz.JobPersistenceException

Recover any failed or misfired jobs and clean up the data store as appropriate.

Overrides:

recoverJobs in class org.quartz.impl.jdbcjobstore.JobStoreSupport

Parameters:

conn -

Throws:

org.quartz.JobPersistenceException

updateCompletedTriggerToWaiting

protected boolean updateCompletedTriggerToWaiting(Connection conn,
                                      String triggerName,
                                      String groupName)
                                           throws org.quartz.JobPersistenceException

Update complete trigger next firing time to trigger start time

Parameters:

conn -

triggerName -

groupName -

Returns:

Throws:

org.quartz.JobPersistenceException