public class ChannelRepodataDriver extends java.lang.Object implements QueueDriver
Constructor and Description |
---|
ChannelRepodataDriver() |
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 |
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
|
public void initialize()
initialize
in interface QueueDriver
public boolean canContinue()
QueueDriver
canContinue
in interface QueueDriver
public java.util.List getCandidates()
QueueDriver
getCandidates
in interface QueueDriver
public org.apache.log4j.Logger getLogger()
QueueDriver
getLogger
in interface QueueDriver
public void setLogger(org.apache.log4j.Logger loggerIn)
setLogger
in interface QueueDriver
loggerIn
- logger to be setpublic int getMaxWorkers()
QueueDriver
getMaxWorkers
in interface QueueDriver
public QueueWorker makeWorker(java.lang.Object workItem)
QueueDriver
makeWorker
in interface QueueDriver
workItem
- work item