Class TaskQueueWithErrorQueueFactory
- java.lang.Object
-
- com.atlassian.confluence.event.queues.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 Summary
Constructors Constructor Description TaskQueueWithErrorQueueFactory(ClusterManager clusterManager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description com.atlassian.core.task.TaskQueueWithErrorQueue
getClusteredQueue(String name)
Returns the task queue for a given name/identifier.com.atlassian.core.task.TaskQueueWithErrorQueue
getLocalQueue(String name)
Returns the task queue for a given name/identifier.
-
-
-
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
-
-