org.openpipeline.scheduler
Class PipelineJobWrapper

java.lang.Object
  org.openpipeline.scheduler.PipelineJobWrapper

All Implemented Interfaces:

org.quartz.InterruptableJob, org.quartz.Job, org.quartz.StatefulJob

public class PipelineJobWrapper
extends Object
implements org.quartz.InterruptableJob, org.quartz.StatefulJob

This class is a wrapper around a class that implements a PipelineJob interface. It implements the Quartz InterruptableJob and StatefulJob interfaces. The purpose of it is to separate pipeline jobs from the Quartz classes, so that you don't need Quartz to be able to execute a pipeline job. When the scheduler needs to run a job, it creates an instance of this class, which internally loads the actual job class and executes it.

Constructor Summary

PipelineJobWrapper()

Method Summary

void	execute(org.quartz.JobExecutionContext jobContext) Load the class specified in the params in the jobContext, and then execute it.
PipelineJob	getPipelineJob() Return the PipelineJob that this object wraps.
void	interrupt() Interrupt an executing job.

Methods inherited from class java.lang.Object

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

Constructor Detail

PipelineJobWrapper

public PipelineJobWrapper()

Method Detail

execute

public void execute(org.quartz.JobExecutionContext jobContext)
             throws org.quartz.JobExecutionException

Load the class specified in the params in the jobContext, and then execute it.

Specified by:

execute in interface org.quartz.Job

Throws:

org.quartz.JobExecutionException

interrupt

public void interrupt()

Interrupt an executing job.

Specified by:

interrupt in interface org.quartz.InterruptableJob

getPipelineJob

public PipelineJob getPipelineJob()

Return the PipelineJob that this object wraps.