Class TransactionalQueueTaskManager

  • All Implemented Interfaces:
    com.atlassian.core.task.MultiQueueTaskManager

    @Transactional
    public class TransactionalQueueTaskManager
    extends Object
    implements com.atlassian.core.task.MultiQueueTaskManager
    An implementation of MultiQueueTaskManager which delegates to another instance, and which adds Transactional annotations.
    Since:
    7.16
    • Constructor Detail

      • TransactionalQueueTaskManager

        public TransactionalQueueTaskManager​(com.atlassian.core.task.MultiQueueTaskManager delegate)
    • Method Detail

      • getTaskQueue

        @Transactional(readOnly=true)
        public com.atlassian.core.task.TaskQueue getTaskQueue​(String queueName)
        Specified by:
        getTaskQueue in interface com.atlassian.core.task.MultiQueueTaskManager
      • addTaskQueue

        public void addTaskQueue​(String queueName,
                                 com.atlassian.core.task.TaskQueue taskQueue)
        Specified by:
        addTaskQueue in interface com.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 interface com.atlassian.core.task.MultiQueueTaskManager
      • setTaskQueues

        public void setTaskQueues​(Map<String,​com.atlassian.core.task.TaskQueue> queues)
        Specified by:
        setTaskQueues in interface com.atlassian.core.task.MultiQueueTaskManager
      • addTask

        public void addTask​(String queueName,
                            com.atlassian.core.task.Task task)
        Specified by:
        addTask in interface com.atlassian.core.task.MultiQueueTaskManager
      • flush

        public void flush​(String queueName)
        Specified by:
        flush in interface com.atlassian.core.task.MultiQueueTaskManager
      • flush

        public void flush()
        Specified by:
        flush in interface com.atlassian.core.task.MultiQueueTaskManager