public class TaskQueueFactory
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
TaskQueue |
createQueue(java.lang.String name,
java.lang.Class driverClass,
org.apache.log4j.Logger loggerIn)
Create the queue, if it doesn't exist already.
|
static TaskQueueFactory |
get()
Get the singleton instance
|
TaskQueue |
getQueue(java.lang.String name)
Retrieves a queue by name
|
TaskQueue |
removeQueue(java.lang.String name)
Removes the queue from the map of available queues.
|
public static TaskQueueFactory get()
public TaskQueue getQueue(java.lang.String name)
name
- queue namepublic TaskQueue createQueue(java.lang.String name, java.lang.Class driverClass, org.apache.log4j.Logger loggerIn) throws java.lang.Exception
name
- queue namedriverClass
- class to use as the queue driverloggerIn
- queue loggerjava.lang.Exception
- error occurred during queue creationpublic TaskQueue removeQueue(java.lang.String name)
name
- queue name