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