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​(ClusterManager clusterManager)
    • Method Detail

      • getClusteredQueue

        public com.atlassian.core.task.TaskQueueWithErrorQueue getClusteredQueue​(String name)
        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