Class ClusteredTaskQueueWithErrorQueue

  • All Implemented Interfaces:
    com.atlassian.core.task.TaskQueue, com.atlassian.core.task.TaskQueueWithErrorQueue

    public class ClusteredTaskQueueWithErrorQueue
    extends com.atlassian.core.task.AbstractErrorQueuedTaskQueue
    • Nested Class Summary

      • Nested classes/interfaces inherited from class com.atlassian.core.task.AbstractErrorQueuedTaskQueue

        com.atlassian.core.task.AbstractErrorQueuedTaskQueue.TaskDecorator
    • Field Summary

      • Fields inherited from class com.atlassian.core.task.AbstractTaskQueue

        buffer, METRIC_NAME, QUEUE_NAME_TAG
    • Method Summary

      • Methods inherited from class com.atlassian.core.task.AbstractErrorQueuedTaskQueue

        addTask, flush, getErrorQueue, getRetryCount, handleException, setRetryCount
      • Methods inherited from class com.atlassian.core.task.AbstractTaskQueue

        clear, getFlushStarted, getQueue, getQueueName, getTasks, isFlushing, size
      • Methods inherited from interface com.atlassian.core.task.TaskQueue

        clear, getFlushStarted, getTasks, isFlushing, size
    • Constructor Detail

      • ClusteredTaskQueueWithErrorQueue

        public ClusteredTaskQueueWithErrorQueue​(String name,
                                                ClusterManager clusterManager)