Class TransactionalQueueTaskManager
- java.lang.Object
-
- com.atlassian.confluence.impl.event.queues.TransactionalQueueTaskManager
-
- All Implemented Interfaces:
com.atlassian.core.task.MultiQueueTaskManager
@Transactional public class TransactionalQueueTaskManager extends Object implements com.atlassian.core.task.MultiQueueTaskManager
An implementation ofMultiQueueTaskManager
which delegates to another instance, and which addsTransactional
annotations.- Since:
- 7.16
-
-
Constructor Summary
Constructors Constructor Description TransactionalQueueTaskManager(com.atlassian.core.task.MultiQueueTaskManager delegate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addTask(String queueName, com.atlassian.core.task.Task task)
void
addTaskQueue(String queueName, com.atlassian.core.task.TaskQueue taskQueue)
void
flush()
void
flush(String queueName)
com.atlassian.core.task.TaskQueue
getTaskQueue(String queueName)
com.atlassian.core.task.TaskQueue
removeTaskQueue(String queueName, com.atlassian.core.task.TaskQueue taskQueue, boolean flush)
void
setTaskQueues(Map<String,com.atlassian.core.task.TaskQueue> queues)
-
-
-
Method Detail
-
getTaskQueue
@Transactional(readOnly=true) public com.atlassian.core.task.TaskQueue getTaskQueue(String queueName)
- Specified by:
getTaskQueue
in interfacecom.atlassian.core.task.MultiQueueTaskManager
-
addTaskQueue
public void addTaskQueue(String queueName, com.atlassian.core.task.TaskQueue taskQueue)
- Specified by:
addTaskQueue
in interfacecom.atlassian.core.task.MultiQueueTaskManager
-
removeTaskQueue
public com.atlassian.core.task.TaskQueue removeTaskQueue(String queueName, com.atlassian.core.task.TaskQueue taskQueue, boolean flush)
- Specified by:
removeTaskQueue
in interfacecom.atlassian.core.task.MultiQueueTaskManager
-
setTaskQueues
public void setTaskQueues(Map<String,com.atlassian.core.task.TaskQueue> queues)
- Specified by:
setTaskQueues
in interfacecom.atlassian.core.task.MultiQueueTaskManager
-
addTask
public void addTask(String queueName, com.atlassian.core.task.Task task)
- Specified by:
addTask
in interfacecom.atlassian.core.task.MultiQueueTaskManager
-
flush
public void flush(String queueName)
- Specified by:
flush
in interfacecom.atlassian.core.task.MultiQueueTaskManager
-
flush
public void flush()
- Specified by:
flush
in interfacecom.atlassian.core.task.MultiQueueTaskManager
-
-