Class TaskQueueWithErrorQueueFactory


  • public class TaskQueueWithErrorQueueFactory
    extends Object
    A simple factory bean to return a correct queue implementation depending on whether we're clustered or not.
    • Constructor Detail

      • TaskQueueWithErrorQueueFactory

        public TaskQueueWithErrorQueueFactory()
        Since:
        8.2
      • TaskQueueWithErrorQueueFactory

        @Deprecated(since="8.2",
                    forRemoval=true)
        public TaskQueueWithErrorQueueFactory​(ClusterManager clusterManager)
        Deprecated, for removal: This API element is subject to removal in a future version.
        since 8.2 no replacement
    • Method Detail

      • getClusteredQueue

        @Deprecated
        public com.atlassian.core.task.TaskQueueWithErrorQueue getClusteredQueue​(String name)
        Deprecated.
        since 8.2 no replacement
        Returns the task queue for a given name/identifier. If we are in a cluster the queue is shared across all clusters is returned.
        Parameters:
        name - - name of the task queue
        Returns:
        a task queue
      • getLocalQueue

        public com.atlassian.core.task.TaskQueueWithErrorQueue getLocalQueue​(String name)
        Returns the task queue for a given name/identifier. The queue returned will only be used by the node that creates it. In a cluster, each node handles a separate queue.
        Parameters:
        name - - the name of the task queue
        Returns:
        a task queue