com.atlassian.scheduler.quartz2

Class Quartz2SchedulerService

java.lang.Object

com.atlassian.scheduler.core.AbstractSchedulerService

com.atlassian.scheduler.quartz2.Quartz2SchedulerService

All Implemented Interfaces:

LifecycleAwareSchedulerService, SchedulerServiceController, SchedulerService

public class Quartz2SchedulerService
extends AbstractSchedulerService

Quartz 2.x implementation of a SchedulerService.

• Job runner keys are mapped to Quartz JobKey names, with the Job being created or destroyed automatically based on whether or not it has any existing Triggers.
• All Quartz Jobs use Quartz2Job, which immediately delegates to JobLauncher.
• Job ids are mapped to Quartz TriggerKey names.
• The parameters map is serialized to a byte[] and stored in the JobDataMap for the Quartz Trigger.

Nested Class Summary

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

LifecycleAwareSchedulerService.State

Field Summary

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

BY_JOB_ID

Constructor Summary

Constructors

Constructor and Description
Quartz2SchedulerService(RunDetailsDao runDetailsDao, Quartz2SchedulerConfiguration config)
Quartz2SchedulerService(RunDetailsDao runDetailsDao, SchedulerServiceConfiguration config, org.quartz.Scheduler localScheduler, org.quartz.Scheduler clusteredScheduler)

Method Summary

Modifier and Type	Method and Description
Date	calculateNextRunTime(Schedule schedule) Returns the next time that a job with the given schedule would be expected to run.
JobDetails	getJobDetails(JobId jobId) Retrieves the details for the specified job ID.
Set<JobRunnerKey>	getJobRunnerKeysForAllScheduledJobs() Returns all of the job runner keys that have been used to schedule jobs, regardless of whether or not JobRunners are currently registered for them.
List<JobDetails>	getJobsByJobRunnerKey(JobRunnerKey jobRunnerKey) Retrieves the job details for all jobs with the given job runner key.
void	scheduleJob(JobId jobId, JobConfig jobConfig) Schedules a job with the given job ID.
protected void	shutdownImpl() Provided by the scheduler service to implement AbstractSchedulerService.shutdown() requests.
protected void	standbyImpl() Stop the threads associated with each quartz scheduler
protected void	startImpl() Start the threads associated with each quartz scheduler.
void	unscheduleJob(JobId jobId) Unschedules a previously scheduled job ID.

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

Quartz2SchedulerService

public Quartz2SchedulerService(RunDetailsDao runDetailsDao,
                               Quartz2SchedulerConfiguration config)
                        throws SchedulerServiceException

Throws:

SchedulerServiceException

Quartz2SchedulerService

public Quartz2SchedulerService(RunDetailsDao runDetailsDao,
                               SchedulerServiceConfiguration config,
                               org.quartz.Scheduler localScheduler,
                               org.quartz.Scheduler clusteredScheduler)
                        throws SchedulerServiceException

Throws:

SchedulerServiceException

Method Detail

scheduleJob

public void scheduleJob(JobId jobId,
                        JobConfig jobConfig)
                 throws SchedulerServiceException

Description copied from interface: SchedulerService

Schedules a job with the given job ID.

If a job already exists with the given ID, then it will be replaced with the new run config. If the schedule is eligible to run immediately and multiple nodes take this action at close to the same time, then the job might run more than once as the instances replace one another.

In most cases, this will be harmless, but it can be avoided by making sure the job will not be eligible to run until some time in the future. For example, when using an interval schedule, the caller can first check whether or not the job already exists, and if it does not then specify an initial start date for the schedule, as in:

     Schedule.forInterval(120000L, new Date(System.currentTimeMillis() + 15000L))
 

Since the schedule will not be eligible to run until 15 seconds after the current time, any race conditions between two nodes starting up at once and trying to schedule the same job should resolve before the job actually fires. For cron expressions, this is a little bit more difficult, but you can set the seconds field to an explicit value to accomplish the same thing. For example:

     final Calendar calendar = new GregorianCalendar();
     calendar.add(15, Calendar.SECOND);
     final Schedule schedule = Schedule.forCronExpression(
             calendar.get(Calendar.SECOND) + " 0 2 * * ?");  // at or just after 2 A.M.
     scheduleJob(...
 

Parameters:

jobId - the Job ID

jobConfig - the configuration details for the job instance including schedule, run mode, run parameters, etc.

Throws:

SchedulerServiceException - if the job cannot be scheduled because there is a problem with either the provided configuration or within the scheduler implementation itself

unscheduleJob

public void unscheduleJob(JobId jobId)

Description copied from interface: SchedulerService

Unschedules a previously scheduled job ID.

If no such job exists, then the request is ignored.

Parameters:

jobId - the Job ID to be unregistered

calculateNextRunTime

@Nullable
public Date calculateNextRunTime(Schedule schedule)
                                    throws SchedulerServiceException

Description copied from interface: SchedulerService

Returns the next time that a job with the given schedule would be expected to run.

Caveats:

• Interval schedules taken from JobDetails are not aware of the job that they came from or whether or not that job has previously run. They are calculated on the basis of the current time, not the original job's history.
• Schedules based on cron expressions are implicitly validated by this request.
• The initial run time reported is not a strong guarantee. The actual initial run time that is calculated by the schedule may depend on the exact time that the schedule is created. The return value should be treated as an estimate, only.

Parameters:

schedule - the schedule to evaluate

Returns:

the estimated time that the schedule would next run, or null if it would never run

Throws:

SchedulerServiceException - if schedule is invalid.

getJobDetails

@Nullable
public JobDetails getJobDetails(JobId jobId)

Description copied from interface: SchedulerService

Retrieves the details for the specified job ID.

Parameters:

jobId - the Job ID for which to retrieve the details

Returns:

the job details, or null if no such job is defined

getJobRunnerKeysForAllScheduledJobs

@Nonnull
public Set<JobRunnerKey> getJobRunnerKeysForAllScheduledJobs()

Description copied from interface: SchedulerService

Returns all of the job runner keys that have been used to schedule jobs, regardless of whether or not JobRunners are currently registered for them. The job runner keys are not guaranteed to be returned in any particular order.

Returns:

an immutable set containing all of the job runner keys with scheduled jobs

See Also:

SchedulerService.getRegisteredJobRunnerKeys()

getJobsByJobRunnerKey

@Nonnull
public List<JobDetails> getJobsByJobRunnerKey(JobRunnerKey jobRunnerKey)

Description copied from interface: SchedulerService

Retrieves the job details for all jobs with the given job runner key.

Parameters:

jobRunnerKey - the job runner key to look up

Returns:

the jobs that are registered with the given job runner key, or an empty collection if there are no jobs that use the given key; never null

startImpl

protected void startImpl()
                  throws SchedulerServiceException

Start the threads associated with each quartz scheduler. It is the responsibility of the underlying JobStores to determine whether or not to trigger jobs which should have run while the scheduler was in standby mode. This is usually controlled by a misfire threshold on the JobStore implementation

Specified by:

startImpl in class AbstractSchedulerService

Throws:

SchedulerServiceException - if the scheduler implementation fails to start

standbyImpl

protected void standbyImpl()
                    throws SchedulerServiceException

Stop the threads associated with each quartz scheduler

Specified by:

standbyImpl in class AbstractSchedulerService

Throws:

SchedulerServiceException - if the scheduler implementation fails to enter standby mode

shutdownImpl

protected void shutdownImpl()

Description copied from class: AbstractSchedulerService

Provided by the scheduler service to implement AbstractSchedulerService.shutdown() requests. This is only ever called if the scheduler has not already been shut down, and throwing an exception does not prevent the scheduler service from entering this state.

Specified by:

shutdownImpl in class AbstractSchedulerService