org.quartz.plugins.interrupt

Class JobInterruptMonitorPlugin

java.lang.Object

org.quartz.listeners.TriggerListenerSupport

org.quartz.plugins.interrupt.JobInterruptMonitorPlugin

All Implemented Interfaces:

SchedulerPlugin, TriggerListener

public class JobInterruptMonitorPlugin
extends TriggerListenerSupport
implements SchedulerPlugin

This plugin catches the event of job running for a long time (more than the configured max time) and tells the scheduler to "try" interrupting it if enabled.

Author:

Rama Chavali

See Also:

Scheduler.interrupt(JobKey)

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	AUTO_INTERRUPTIBLE
static java.lang.String	MAX_RUN_TIME

Constructor Summary

Constructors

Constructor and Description
JobInterruptMonitorPlugin()

Method Summary

Modifier and Type	Method and Description
long	getDefaultMaxRunTime()
protected org.slf4j.Logger	getLog() Get the Logger for this class's category.
java.lang.String	getName() Get the name of the TriggerListener.
void	initialize(java.lang.String name, Scheduler scheduler, ClassLoadHelper helper) Called during creation of the Scheduler in order to give the SchedulerPlugin a chance to initialize.
java.util.concurrent.ScheduledFuture	scheduleJobInterruptMonitor(JobKey jobkey, long delay)
void	setDefaultMaxRunTime(long defaultMaxRunTime)
void	shutdown() Called in order to inform the SchedulerPlugin that it should free up all of it's resources because the scheduler is shutting down.
void	start() Called when the associated Scheduler is started, in order to let the plug-in know it can now make calls into the scheduler if it needs to.
void	triggerComplete(Trigger trigger, JobExecutionContext context, Trigger.CompletedExecutionInstruction triggerInstructionCode) Called by the Scheduler when a Trigger has fired, it's associated JobDetail has been executed, and it's triggered(xx) method has been called.
void	triggerFired(Trigger trigger, JobExecutionContext context) Called by the Scheduler when a Trigger has fired, and it's associated JobDetail is about to be executed.

Methods inherited from class org.quartz.listeners.TriggerListenerSupport

triggerMisfired, vetoJobExecution

Methods inherited from class java.lang.Object

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

Field Detail

AUTO_INTERRUPTIBLE

public static final java.lang.String AUTO_INTERRUPTIBLE

See Also:

Constant Field Values

MAX_RUN_TIME

public static final java.lang.String MAX_RUN_TIME

See Also:

Constant Field Values

Constructor Detail

JobInterruptMonitorPlugin

public JobInterruptMonitorPlugin()

Method Detail

start

public void start()

Description copied from interface: SchedulerPlugin

Called when the associated Scheduler is started, in order to let the plug-in know it can now make calls into the scheduler if it needs to.

Specified by:

start in interface SchedulerPlugin

shutdown

public void shutdown()

Description copied from interface: SchedulerPlugin

Called in order to inform the SchedulerPlugin that it should free up all of it's resources because the scheduler is shutting down.

Specified by:

shutdown in interface SchedulerPlugin

getLog

protected org.slf4j.Logger getLog()

Description copied from class: TriggerListenerSupport

Get the Logger for this class's category. This should be used by subclasses for logging.

Overrides:

getLog in class TriggerListenerSupport

scheduleJobInterruptMonitor

public java.util.concurrent.ScheduledFuture scheduleJobInterruptMonitor(JobKey jobkey,
                                                                        long delay)

getDefaultMaxRunTime

public long getDefaultMaxRunTime()

setDefaultMaxRunTime

public void setDefaultMaxRunTime(long defaultMaxRunTime)

getName

public java.lang.String getName()

Description copied from interface: TriggerListener

Get the name of the TriggerListener.

Specified by:

getName in interface TriggerListener

triggerFired

public void triggerFired(Trigger trigger,
                         JobExecutionContext context)

Description copied from interface: TriggerListener

Called by the Scheduler when a Trigger has fired, and it's associated JobDetail is about to be executed.

It is called before the vetoJobExecution(..) method of this interface.

Specified by:

triggerFired in interface TriggerListener

Overrides:

triggerFired in class TriggerListenerSupport

Parameters:

trigger - The Trigger that has fired.

context - The JobExecutionContext that will be passed to the Job'sexecute(xx) method.

triggerComplete

public void triggerComplete(Trigger trigger,
                            JobExecutionContext context,
                            Trigger.CompletedExecutionInstruction triggerInstructionCode)

Description copied from interface: TriggerListener

Called by the Scheduler when a Trigger has fired, it's associated JobDetail has been executed, and it's triggered(xx) method has been called.

Specified by:

triggerComplete in interface TriggerListener

Overrides:

triggerComplete in class TriggerListenerSupport

Parameters:

trigger - The Trigger that was fired.

context - The JobExecutionContext that was passed to the Job'sexecute(xx) method.

triggerInstructionCode - the result of the call on the Trigger'striggered(xx) method.

initialize

public void initialize(java.lang.String name,
                       Scheduler scheduler,
                       ClassLoadHelper helper)
                throws SchedulerException

Description copied from interface: SchedulerPlugin

Called during creation of the Scheduler in order to give the SchedulerPlugin a chance to initialize.

At this point, the Scheduler's JobStore is not yet initialized.

If you need direct access your plugin, for example during Job execution, you can have this method explicitly put a reference to this plugin in the Scheduler's SchedulerContext.

Specified by:

initialize in interface SchedulerPlugin

Parameters:

name - The name by which the plugin is identified.

scheduler - The scheduler to which the plugin is registered.

helper - The classLoadHelper the SchedulerFactory is actually using

Throws:

SchedulerConfigException - if there is an error initializing.

SchedulerException