com.atlassian.core.task
Class DefaultMultiQueueTaskManager

java.lang.Object
  com.atlassian.core.task.DefaultMultiQueueTaskManager

All Implemented Interfaces:

MultiQueueTaskManager

public class DefaultMultiQueueTaskManager
extends java.lang.Object
implements MultiQueueTaskManager

A TaskManager implementation that manages multiple queues

Constructor Summary

DefaultMultiQueueTaskManager(java.util.Map queues)

DefaultMultiQueueTaskManager(java.lang.String queueName, TaskQueue queue)

Method Summary

void	addTask(java.lang.String queueName, Task task)
void	addTaskQueue(java.lang.String name, TaskQueue queue)
void	flush()
void	flush(java.lang.String queueName)
TaskQueue	getTaskQueue(java.lang.String name)
TaskQueue	removeTaskQueue(java.lang.String queueName, TaskQueue taskQueue, boolean flush)
void	setTaskQueues(java.util.Map queues)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultMultiQueueTaskManager

public DefaultMultiQueueTaskManager(java.lang.String queueName,
                                    TaskQueue queue)

DefaultMultiQueueTaskManager

public DefaultMultiQueueTaskManager(java.util.Map queues)

Method Detail

addTaskQueue

public void addTaskQueue(java.lang.String name,
                         TaskQueue queue)

Specified by:

addTaskQueue in interface MultiQueueTaskManager

removeTaskQueue

public TaskQueue removeTaskQueue(java.lang.String queueName,
                                 TaskQueue taskQueue,
                                 boolean flush)

Specified by:

removeTaskQueue in interface MultiQueueTaskManager

getTaskQueue

public TaskQueue getTaskQueue(java.lang.String name)

Specified by:

getTaskQueue in interface MultiQueueTaskManager

setTaskQueues

public void setTaskQueues(java.util.Map queues)

Specified by:

setTaskQueues in interface MultiQueueTaskManager

addTask

public void addTask(java.lang.String queueName,
                    Task task)

Specified by:

addTask in interface MultiQueueTaskManager

flush

public void flush(java.lang.String queueName)

Specified by:

flush in interface MultiQueueTaskManager

flush

public void flush()

Specified by:

flush in interface MultiQueueTaskManager