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 QueueDriverpublic boolean canContinue()
QueueDrivercanContinue in interface QueueDriverpublic java.util.List getCandidates()
QueueDrivergetCandidates in interface QueueDriverpublic org.apache.log4j.Logger getLogger()
QueueDrivergetLogger in interface QueueDriverpublic void setLogger(org.apache.log4j.Logger loggerIn)
setLogger in interface QueueDriverloggerIn - logger to be setpublic int getMaxWorkers()
QueueDrivergetMaxWorkers in interface QueueDriverpublic QueueWorker makeWorker(java.lang.Object workItem)
QueueDrivermakeWorker in interface QueueDriverworkItem - work item