com.atlassian.confluence.event.queues
Class TaskQueueWithErrorQueueFactory

java.lang.Object
  extended by 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
TaskQueueWithErrorQueueFactory(ClusterManager clusterManager)
           
 
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
 

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


Copyright © 2003-2012 Atlassian. All Rights Reserved.