public class SynchronousQueueService extends AbstractQueueService implements LifecycleQueueService
m_listeners
m_bundleContext
ASYNCHRONOUS_QUEUE_MODE, GLOABL_QUEUE_SCOPE, PREFERENCE_QUEUE_MODE, QUEUE_MODE_PROPERTY, QUEUE_SCOPE_PROPERTY, SYNCHRONOUS_QUEUE_MODE
Constructor and Description |
---|
SynchronousQueueService(org.osgi.framework.BundleContext bundleContext) |
Modifier and Type | Method and Description |
---|---|
int |
getCurrents() |
int |
getFinished() |
protected java.util.Dictionary<java.lang.String,?> |
getServiceProperties() |
int |
getWaiters() |
java.util.List<JobInfo> |
getWaitersInfo() |
<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, fireEnlistedJobInfo, fireExecutedJobInfo, fireFailedJobInfo, fireStartedJobInfo, removeQueueListener
getBundleContext, getRegistration, isRegistered, registerService, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addQueueListener, removeQueueListener
public SynchronousQueueService(org.osgi.framework.BundleContext bundleContext)
protected java.util.Dictionary<java.lang.String,?> getServiceProperties()
getServiceProperties
in class AbstractService
public int getFinished()
getFinished
in interface QueueService
public int getWaiters()
getWaiters
in interface QueueService
public int getCurrents()
getCurrents
in interface QueueService
public java.util.List<JobInfo> getWaitersInfo()
getWaitersInfo
in interface QueueService
public <T> java.util.concurrent.Future<T> submit(Job<T> callable, Callback<T> callback, java.lang.String description)
QueueService
submit
in interface QueueService
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
callable
- the jobdescription
- a description of the jobpublic <T> java.util.concurrent.Future<T> submit(Job<T> callable)
QueueService
submit
in interface QueueService
callable
- the jobCopyright © 2006-2014 The Apache Software Foundation. All Rights Reserved.