public final class ParallelJobQueue extends AbstractJobQueue
JobStatusNotifier.NotifierContext
configuration, isWaiting, logger, queueName, running, services
CONTEXT_PROPERTY_NAME
Constructor and Description |
---|
ParallelJobQueue(String name,
InternalQueueConfiguration config,
QueueServices services,
Set<String> topics) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
canBeClosed()
Check whether this queue can be closed
|
String |
getStateInfo()
Return some information about the current state of the queue.
|
protected void |
notifyFinished(boolean reschedule) |
protected void |
reschedule(JobHandler handler) |
protected void |
start(JobHandler handler)
Start processing of a new job.
|
checkForUnprocessedJobs, clear, close, executeJob, finishedJob, getConfiguration, getName, getRetryDelay, getState, getStatistics, ignoreException, isOutdated, isSuspended, outdate, removeAll, resume, sendAcknowledge, start, stopJob, suspend, tryToClose, wakeUpQueue
public ParallelJobQueue(String name, InternalQueueConfiguration config, QueueServices services, Set<String> topics)
public String getStateInfo()
Queue
getStateInfo
in interface Queue
getStateInfo
in class AbstractJobQueue
Queue.getStateInfo()
protected void start(JobHandler handler)
AbstractJobQueue
start
in class AbstractJobQueue
handler
- The new job handlerprotected boolean canBeClosed()
AbstractJobQueue
canBeClosed
in class AbstractJobQueue
protected void notifyFinished(boolean reschedule)
notifyFinished
in class AbstractJobQueue
protected void reschedule(JobHandler handler)
reschedule
in class AbstractJobQueue
Copyright © 2007–2014 The Apache Software Foundation. All rights reserved.