com.redhat.rhn.taskomatic.task.errata

Class ErrataCacheDriver

java.lang.Object

com.redhat.rhn.taskomatic.task.errata.ErrataCacheDriver

All Implemented Interfaces:

QueueDriver

public class ErrataCacheDriver
extends java.lang.Object
implements QueueDriver

Driver for the threaded errata cache update queue

Constructor Summary

Constructors

Constructor and Description
ErrataCacheDriver()

Method Summary

Modifier and Type	Method and Description
boolean	canContinue() Logic to tell the queue when to stop running Queues will always stop when there is no more work to do.
java.util.List<Task>	getCandidates() List of work items to "prime" the queue
org.apache.log4j.Logger	getLogger() The logger to use for all logging operations
int	getMaxWorkers() Maximum number of worker threads to run
void	initialize() Actions that has to be executed, when queue is created
QueueWorker	makeWorker(java.lang.Object workItem) Create a worker instance to work on a particular work item
void	setLogger(org.apache.log4j.Logger loggerIn) Set the logger to use for all logging operations

Methods inherited from class java.lang.Object

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

Constructor Detail

ErrataCacheDriver

public ErrataCacheDriver()

Method Detail

canContinue

public boolean canContinue()

Logic to tell the queue when to stop running Queues will always stop when there is no more work to do. This method can return false to cause the queue to stop early.

Specified by:

canContinue in interface QueueDriver

Returns:

true if processing can continue, otherwise false

getCandidates

public java.util.List<Task> getCandidates()

List of work items to "prime" the queue

Specified by:

getCandidates in interface QueueDriver

Returns:

list of work items

getLogger

public org.apache.log4j.Logger getLogger()

The logger to use for all logging operations

Specified by:

getLogger in interface QueueDriver

Returns:

log4j Logger

setLogger

public void setLogger(org.apache.log4j.Logger loggerIn)

Set the logger to use for all logging operations

Specified by:

setLogger in interface QueueDriver

Parameters:

loggerIn - logger to be set

getMaxWorkers

public int getMaxWorkers()

Maximum number of worker threads to run

Specified by:

getMaxWorkers in interface QueueDriver

Returns:

number of worker threads

makeWorker

public QueueWorker makeWorker(java.lang.Object workItem)

Create a worker instance to work on a particular work item

Specified by:

makeWorker in interface QueueDriver

Parameters:

workItem - object contained in the list returned from getCandidates()

Returns:

worker instance

initialize

public void initialize()

Actions that has to be executed, when queue is created

Specified by:

initialize in interface QueueDriver