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.

Constructor Summary

Constructors

Constructor and Description
TaskQueueWithErrorQueueFactory(ClusterManager clusterManager)

Method Summary

Modifier and Type	Method and 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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 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