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:

CrowdSchedulerService

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 and Description
InternalLocalScheduler()

Method Summary

Modifier and Type	Method and 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, createParameterMapSerializer, enqueueJob, executeQueuedJob, getJobDetails, getJobRunnerKeysForAllScheduledJobs, getJobsByJobRunnerKey, getPendingJobs, refreshClusteredJob, refreshClusteredJobs, shutdownImpl, standbyImpl, startImpl, unscheduleJob

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

addRunDetails, checked, getJobRunner, getLocallyRunningJobs, getParameterMapSerializer, getRegisteredJobRunnerKeys, getState, postJob, preJob, registerJobRunner, 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 Detail

InternalLocalScheduler

public InternalLocalScheduler()

Method Detail

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