Package org.apache.cxf.bus.managers
Class WorkQueueManagerImpl
- java.lang.Object
-
- org.apache.cxf.bus.managers.WorkQueueManagerImpl
-
- All Implemented Interfaces:
WorkQueueManager
public class WorkQueueManagerImpl extends Object implements WorkQueueManager
-
-
Field Summary
Fields Modifier and Type Field Description static StringDEFAULT_QUEUE_NAMEstatic StringDEFAULT_WORKQUEUE_BEAN_NAME
-
Constructor Summary
Constructors Constructor Description WorkQueueManagerImpl()WorkQueueManagerImpl(Bus b)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddNamedWorkQueue(String name, AutomaticWorkQueue q)Adds a named work queueAutomaticWorkQueuegetAutomaticWorkQueue()Get the manager's default work queue.BusgetBus()AutomaticWorkQueuegetNamedWorkQueue(String name)Get the named work queue.voidrun()Only returns after workqueue has been shutdown.voidsetBus(Bus bus)voidshutdown(boolean processRemainingTasks)Shuts down the manager's work queue.
-
-
-
Field Detail
-
DEFAULT_QUEUE_NAME
public static final String DEFAULT_QUEUE_NAME
- See Also:
- Constant Field Values
-
DEFAULT_WORKQUEUE_BEAN_NAME
public static final String DEFAULT_WORKQUEUE_BEAN_NAME
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
WorkQueueManagerImpl
public WorkQueueManagerImpl()
-
WorkQueueManagerImpl
public WorkQueueManagerImpl(Bus b)
-
-
Method Detail
-
getBus
public Bus getBus()
-
setBus
public final void setBus(Bus bus)
-
getAutomaticWorkQueue
public AutomaticWorkQueue getAutomaticWorkQueue()
Description copied from interface:WorkQueueManagerGet the manager's default work queue.- Specified by:
getAutomaticWorkQueuein interfaceWorkQueueManager- Returns:
- AutomaticWorkQueue
-
shutdown
public void shutdown(boolean processRemainingTasks)
Description copied from interface:WorkQueueManagerShuts down the manager's work queue. IfprocessRemainingTasksis true, waits for the work queue to shutdown before returning.- Specified by:
shutdownin interfaceWorkQueueManager- Parameters:
processRemainingTasks- - whether or not to wait for completion
-
run
public void run()
Description copied from interface:WorkQueueManagerOnly returns after workqueue has been shutdown.- Specified by:
runin interfaceWorkQueueManager
-
getNamedWorkQueue
public AutomaticWorkQueue getNamedWorkQueue(String name)
Description copied from interface:WorkQueueManagerGet the named work queue.- Specified by:
getNamedWorkQueuein interfaceWorkQueueManager- Returns:
- AutomaticWorkQueue
-
addNamedWorkQueue
public final void addNamedWorkQueue(String name, AutomaticWorkQueue q)
Description copied from interface:WorkQueueManagerAdds a named work queue- Specified by:
addNamedWorkQueuein interfaceWorkQueueManager
-
-