Package com.atlassian.crowd.scheduling

Class InternalLocalScheduler

java.lang.Object
com.atlassian.scheduler.core.AbstractSchedulerService
com.atlassian.scheduler.caesium.impl.CaesiumSchedulerService
com.atlassian.crowd.scheduling.InternalLocalScheduler
All Implemented Interfaces:
com.atlassian.scheduler.core.LifecycleAwareSchedulerService, com.atlassian.scheduler.core.SchedulerServiceController, com.atlassian.scheduler.SchedulerService
public class InternalLocalScheduler extends com.atlassian.scheduler.caesium.impl.CaesiumSchedulerService
An internal, node-local scheduler. Intended for time-sensitive jobs, like heartbeats. Not intended for general usage. Will reject jobs that are not local, and will only allow as many jobs as worker threads configured to guarantee availability.
See Also:

  • Nested Class Summary

    Nested classes/interfaces inherited from interface com.atlassian.scheduler.core.LifecycleAwareSchedulerService

    com.atlassian.scheduler.core.LifecycleAwareSchedulerService.State

  • Field Summary

    Fields inherited from class com.atlassian.scheduler.core.AbstractSchedulerService

    BY_JOB_ID

  • Constructor Summary

    Constructors
    Constructor
    Description
    InternalLocalScheduler()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    scheduleJob(com.atlassian.scheduler.config.JobId jobId, com.atlassian.scheduler.config.JobConfig jobConfig)
     

    Methods inherited from class com.atlassian.scheduler.caesium.impl.CaesiumSchedulerService

    calculateNextRunTime, calculateNextRunTime, createParameterMapSerializer, enqueueJob, executeQueuedJob, getJobDetails, getJobRunnerKeysForAllScheduledJobs, getJobsByJobRunnerKey, getJobsByJobRunnerKeys, getPendingJobs, refreshClusteredJob, refreshClusteredJobs, registerJobRunner, shutdownImpl, standbyImpl, startImpl, unscheduleJob

    Methods inherited from class com.atlassian.scheduler.core.AbstractSchedulerService

    addRunDetails, checked, getJobRunner, getLocallyRunningJobs, getParameterMapSerializer, getRegisteredJobRunnerKeys, getState, postJob, preJob, scheduleJobWithGeneratedId, shutdown, standby, start, unregisterJobRunner, waitUntilIdle

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • InternalLocalScheduler

      public InternalLocalScheduler()

  • Method Details

    • scheduleJob

      public void scheduleJob(com.atlassian.scheduler.config.JobId jobId, com.atlassian.scheduler.config.JobConfig jobConfig) throws com.atlassian.scheduler.SchedulerServiceException
      Specified by:
      scheduleJob in interface com.atlassian.scheduler.SchedulerService
      Overrides:
      scheduleJob in class com.atlassian.scheduler.caesium.impl.CaesiumSchedulerService
      Throws:
      com.atlassian.scheduler.SchedulerServiceException