public class WorkQueueManagerImpl extends Object implements WorkQueueManager
| Modifier and Type | Field and Description |
|---|---|
static String |
DEFAULT_QUEUE_NAME |
static String |
DEFAULT_WORKQUEUE_BEAN_NAME |
| Constructor and Description |
|---|
WorkQueueManagerImpl() |
WorkQueueManagerImpl(Bus b) |
| Modifier and Type | Method and Description |
|---|---|
void |
addNamedWorkQueue(String name,
AutomaticWorkQueue q)
Adds a named work queue
|
AutomaticWorkQueue |
getAutomaticWorkQueue()
Get the manager's default work queue.
|
Bus |
getBus() |
AutomaticWorkQueue |
getNamedWorkQueue(String name)
Get the named work queue.
|
void |
run()
Only returns after workqueue has been shutdown.
|
void |
setBus(Bus bus) |
void |
shutdown(boolean processRemainingTasks)
Shuts down the manager's work queue.
|
public static final String DEFAULT_QUEUE_NAME
public static final String DEFAULT_WORKQUEUE_BEAN_NAME
public WorkQueueManagerImpl()
public WorkQueueManagerImpl(Bus b)
public Bus getBus()
public final void setBus(Bus bus)
public AutomaticWorkQueue getAutomaticWorkQueue()
WorkQueueManagergetAutomaticWorkQueue in interface WorkQueueManagerpublic void shutdown(boolean processRemainingTasks)
WorkQueueManagerprocessRemainingTasks is true, waits for the work queue to
shutdown before returning.shutdown in interface WorkQueueManagerprocessRemainingTasks - - whether or not to wait for completionpublic void run()
WorkQueueManagerrun in interface WorkQueueManagerpublic AutomaticWorkQueue getNamedWorkQueue(String name)
WorkQueueManagergetNamedWorkQueue in interface WorkQueueManagerpublic final void addNamedWorkQueue(String name, AutomaticWorkQueue q)
WorkQueueManageraddNamedWorkQueue in interface WorkQueueManagerApache CXF