com.redhat.rhn.taskomatic.task

Class RhnQueueJob

java.lang.Object

com.redhat.rhn.taskomatic.task.RhnQueueJob

All Implemented Interfaces:

RhnJob, org.quartz.Job

Direct Known Subclasses:

ChannelRepodata, ErrataCacheTask, ErrataQueue

public abstract class RhnQueueJob
extends java.lang.Object
implements RhnJob

Custom Quartz Job implementation which only allows one thread to run at a time. All other threads return without performing any work. This policy was chosen instead of blocking so as to reduce threading problems inside Quartz itself.

Field Summary

Fields inherited from interface com.redhat.rhn.taskomatic.task.RhnJob

DEFAULT_LOGGING_LAYOUT

Constructor Summary

Constructors

Constructor and Description
RhnQueueJob()

Method Summary

Modifier and Type	Method and Description
void	appendExceptionToLogError(java.lang.Exception e) appends an exception message to log error useful in case job failed to start
void	execute(org.quartz.JobExecutionContext ctx)
void	execute(org.quartz.JobExecutionContext ctx, TaskoRun runIn) execute method to be called
protected abstract java.lang.Class	getDriverClass()
protected abstract org.apache.log4j.Logger	getLogger()
protected abstract java.lang.String	getQueueName()
TaskoRun	getRun()
void	setJobRun(TaskoRun runIn)

Methods inherited from class java.lang.Object

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

Constructor Detail

RhnQueueJob

public RhnQueueJob()

Method Detail

getLogger

protected abstract org.apache.log4j.Logger getLogger()

appendExceptionToLogError

public void appendExceptionToLogError(java.lang.Exception e)

appends an exception message to log error useful in case job failed to start

Specified by:

appendExceptionToLogError in interface RhnJob

Parameters:

e - exception

execute

public void execute(org.quartz.JobExecutionContext ctx,
                    TaskoRun runIn)
             throws org.quartz.JobExecutionException

execute method to be called

Specified by:

execute in interface RhnJob

Parameters:

ctx - job context

runIn - associated run

Throws:

org.quartz.JobExecutionException - thrown in case of any runtime exception

execute

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

Specified by:

execute in interface org.quartz.Job

Throws:

org.quartz.JobExecutionException

getRun

public TaskoRun getRun()

Returns:

Returns the run.

setJobRun

public void setJobRun(TaskoRun runIn)

Parameters:

runIn - The run to set.

getDriverClass

protected abstract java.lang.Class getDriverClass()

getQueueName

protected abstract java.lang.String getQueueName()