public class EnforcedQueueService extends ForwardingQueueService
ASYNCHRONOUS_QUEUE_MODE, GLOABL_QUEUE_SCOPE, PREFERENCE_QUEUE_MODE, QUEUE_MODE_PROPERTY, QUEUE_SCOPE_PROPERTY, SYNCHRONOUS_QUEUE_MODE
Constructor and Description |
---|
EnforcedQueueService(PreferenceSelection strategy,
LifecycleQueueService queueService,
Preference enforced,
Log logger)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected LifecycleQueueService |
delegate() |
<T> java.util.concurrent.Future<T> |
submit(Job<T> callable)
Submits a job to the queue service.
|
<T> java.util.concurrent.Future<T> |
submit(Job<T> callable,
Callback<T> callback,
java.lang.String description)
Submits a job to the queue service.
|
<T> java.util.concurrent.Future<T> |
submit(Job<T> callable,
java.lang.String description)
Submits a job to the queue service.
|
addQueueListener, getCurrents, getFinished, getWaiters, getWaitersInfo, removeQueueListener, start, stop
public EnforcedQueueService(PreferenceSelection strategy, LifecycleQueueService queueService, Preference enforced, Log logger)
strategy
- the strategyqueueService
- the queue serviceenforced
- the preference we want to enforcelogger
- the loggerprotected LifecycleQueueService delegate()
delegate
in class ForwardingQueueService
public <T> java.util.concurrent.Future<T> submit(Job<T> callable, Callback<T> callback, java.lang.String description)
QueueService
submit
in interface QueueService
submit
in class ForwardingQueueService
callable
- the jobcallback
- callback called when the job is processeddescription
- a description of the jobpublic <T> java.util.concurrent.Future<T> submit(Job<T> callable, java.lang.String description)
QueueService
submit
in interface QueueService
submit
in class ForwardingQueueService
callable
- the jobdescription
- a description of the jobpublic <T> java.util.concurrent.Future<T> submit(Job<T> callable)
QueueService
submit
in interface QueueService
submit
in class ForwardingQueueService
callable
- the jobCopyright © 2006-2014 The Apache Software Foundation. All Rights Reserved.