com.atlassian.confluence.event.queues
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.
Method Summary |
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. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TaskQueueWithErrorQueueFactory
public TaskQueueWithErrorQueueFactory(ClusterManager clusterManager)
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 qeue
- 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
Copyright © 2003-2012 Atlassian. All Rights Reserved.