Package org.openbravo.scheduling.quartz

Class OpenbravoPersistentJobStore

  • All Implemented Interfaces:
    org.quartz.impl.jdbcjobstore.Constants, org.quartz.spi.JobStore
    public class OpenbravoPersistentJobStore
extends org.quartz.impl.jdbcjobstore.JobStoreSupport
    Handles persistence of quartz jobs and scheduler status in Database
    See Also:
    JobStoreSupport

    • 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<T extends Object>, org.quartz.impl.jdbcjobstore.JobStoreSupport.TransactionValidator<T extends Object>, org.quartz.impl.jdbcjobstore.JobStoreSupport.VoidTransactionCallback

    • Field Summary

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

        calendarCache, delegateClass, delegateClassName, delegateInitString, dsName, firstCheckIn, instanceId, instanceName, lastCheckin, 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_NONCONCURRENT, COL_IS_UPDATE_DATA, COL_IS_VOLATILE, COL_JOB_CLASS, COL_JOB_DATAMAP, COL_JOB_GROUP, 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_SCHED_TIME, COL_SCHEDULER_NAME, COL_START_TIME, COL_TIME_ZONE_ID, COL_TIMES_TRIGGERED, COL_TRIGGER_GROUP, 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_LOCKS, TABLE_PAUSED_TRIGGERS, TABLE_SCHEDULER_STATE, TABLE_SIMPLE_TRIGGERS, TABLE_TRIGGERS, TTYPE_BLOB, TTYPE_CAL_INT, TTYPE_CRON, TTYPE_DAILY_TIME_INT, TTYPE_SIMPLE

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected <T> T executeInLock​(String lockName, org.quartz.impl.jdbcjobstore.JobStoreSupport.TransactionCallback<T> txCallback)  
      protected Connection getNonManagedTXConnection()  
      boolean isSchedulingAllowed()  
      static boolean isSchedulingAllowedInCluster​(String instanceName)  
      void releaseAcquiredTrigger​(org.quartz.spi.OperableTrigger trigger)  
      void schedulerPaused()  
      void schedulerResumed()  
      void schedulerStarted()  
      void setInstanceName​(String instanceName)  
      void shutdown()
      Shuts down the killableProcessHandler

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

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

    • Constructor Detail

      • OpenbravoPersistentJobStore

        public OpenbravoPersistentJobStore()

    • Method Detail

      • setInstanceName

        public void setInstanceName​(String instanceName)
        Specified by:
        setInstanceName in interface org.quartz.spi.JobStore
        Overrides:
        setInstanceName in class org.quartz.impl.jdbcjobstore.JobStoreSupport

      • schedulerPaused

        public void schedulerPaused()
        Specified by:
        schedulerPaused in interface org.quartz.spi.JobStore
        Overrides:
        schedulerPaused in class org.quartz.impl.jdbcjobstore.JobStoreSupport

      • schedulerStarted

        public void schedulerStarted()
        Specified by:
        schedulerStarted in interface org.quartz.spi.JobStore
        Overrides:
        schedulerStarted in class org.quartz.impl.jdbcjobstore.JobStoreSupport

      • schedulerResumed

        public void schedulerResumed()
        Specified by:
        schedulerResumed in interface org.quartz.spi.JobStore
        Overrides:
        schedulerResumed in class org.quartz.impl.jdbcjobstore.JobStoreSupport

      • shutdown

        public void shutdown()
        Shuts down the killableProcessHandler
        Specified by:
        shutdown in interface org.quartz.spi.JobStore
        Overrides:
        shutdown in class org.quartz.impl.jdbcjobstore.JobStoreSupport

      • isSchedulingAllowed

        public boolean isSchedulingAllowed()

      • isSchedulingAllowedInCluster

        public static boolean isSchedulingAllowedInCluster​(String instanceName)

      • getNonManagedTXConnection

        protected Connection getNonManagedTXConnection()
                                        throws org.quartz.JobPersistenceException
        Specified by:
        getNonManagedTXConnection in class org.quartz.impl.jdbcjobstore.JobStoreSupport
        Throws:
        org.quartz.JobPersistenceException

      • executeInLock

        protected <T> T executeInLock​(String lockName,
                              org.quartz.impl.jdbcjobstore.JobStoreSupport.TransactionCallback<T> txCallback)
                       throws org.quartz.JobPersistenceException
        Specified by:
        executeInLock in class org.quartz.impl.jdbcjobstore.JobStoreSupport
        Throws:
        org.quartz.JobPersistenceException

      • releaseAcquiredTrigger

        public void releaseAcquiredTrigger​(org.quartz.spi.OperableTrigger trigger)
        Specified by:
        releaseAcquiredTrigger in interface org.quartz.spi.JobStore
        Overrides:
        releaseAcquiredTrigger in class org.quartz.impl.jdbcjobstore.JobStoreSupport