io.stallion.jobs

Class JobCoordinator

java.lang.Object

java.lang.Thread

io.stallion.jobs.JobCoordinator

All Implemented Interfaces:

Runnable

public class JobCoordinator
extends Thread

A service that handles running recurring jobs in the background.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

Modifier and Type	Method and Description
List<JobHealthInfo>	buildJobHealthInfos() Get a list of the health of all jobs.
void	executeJobsForCurrentTime(ZonedDateTime now) This really should not be a public method, but needs to be so unittests can access it.
void	forceRunJob(String jobName, boolean forceEvenIfLocked)
JobDefinition	getJobDefinition(String name)
static void	initForTesting() Creates an instance, but does not start it.
static JobCoordinator	instance()
void	registerJob(JobDefinition job) Register the given job definition to be run as a recurring class
void	registerJobForTest(JobDefinition job, ZonedDateTime now) Called by unittests to load the job, with dateTime passed in to override the current time
void	run()
static void	shutdown()
static void	startUp()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Method Detail

instance

public static JobCoordinator instance()

startUp

public static void startUp()

initForTesting

public static void initForTesting()

Creates an instance, but does not start it. Used by unittests.

shutdown

public static void shutdown()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

executeJobsForCurrentTime

public void executeJobsForCurrentTime(ZonedDateTime now)
                               throws ClassNotFoundException,
                                      IllegalAccessException,
                                      InstantiationException

This really should not be a public method, but needs to be so unittests can access it. This is called by the main run() loop to actually find jobs to run and trigger their running

Parameters:

now -

Throws:

ClassNotFoundException

IllegalAccessException

InstantiationException

forceRunJob

public void forceRunJob(String jobName,
                        boolean forceEvenIfLocked)

registerJob

public void registerJob(JobDefinition job)

Register the given job definition to be run as a recurring class

Parameters:

job -

registerJobForTest

public void registerJobForTest(JobDefinition job,
                               ZonedDateTime now)

Called by unittests to load the job, with dateTime passed in to override the current time

Parameters:

job -

now -

getJobDefinition

public JobDefinition getJobDefinition(String name)

buildJobHealthInfos

public List<JobHealthInfo> buildJobHealthInfos()

Get a list of the health of all jobs.

Returns: