com.atlassian.core.task

Class AbstractErrorQueuedTaskQueue

java.lang.Object

com.atlassian.core.task.AbstractTaskQueue

com.atlassian.core.task.AbstractErrorQueuedTaskQueue

All Implemented Interfaces:

TaskQueue, TaskQueueWithErrorQueue

Direct Known Subclasses:

ErrorQueuedTaskQueue

public class AbstractErrorQueuedTaskQueue
extends AbstractTaskQueue
implements TaskQueueWithErrorQueue

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractErrorQueuedTaskQueue.TaskDecorator

Field Summary

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

buffer

Constructor Summary

Constructors

Constructor and Description
AbstractErrorQueuedTaskQueue(TaskQueue errorQueue, FifoBuffer<Task> buffer)

Method Summary

Methods

Modifier and Type	Method and Description
void	addTask(Task task) Adds a task to the end of the queue
void	flush() Will execute every task in the queue
TaskQueue	getErrorQueue()
int	getRetryCount()
protected void	handleException(Task task, Exception rootException)
void	setRetryCount(int retryCount)

Methods inherited from class com.atlassian.core.task.AbstractTaskQueue

clear, getFlushStarted, getQueue, getTasks, isFlushing, size

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.atlassian.core.task.TaskQueue

clear, getFlushStarted, getTasks, isFlushing, size

Constructor Detail

AbstractErrorQueuedTaskQueue

public AbstractErrorQueuedTaskQueue(TaskQueue errorQueue,
                            FifoBuffer<Task> buffer)

Method Detail

flush

public void flush()

Description copied from interface: TaskQueue

Will execute every task in the queue

Specified by:

flush in interface TaskQueue

Overrides:

flush in class AbstractTaskQueue

handleException

protected void handleException(Task task,
                   Exception rootException)

Overrides:

handleException in class AbstractTaskQueue

addTask

public void addTask(Task task)

Description copied from interface: TaskQueue

Adds a task to the end of the queue

Specified by:

addTask in interface TaskQueue

Overrides:

addTask in class AbstractTaskQueue

Parameters:

task - the task to add

getErrorQueue

public TaskQueue getErrorQueue()

Specified by:

getErrorQueue in interface TaskQueueWithErrorQueue

getRetryCount

public int getRetryCount()

setRetryCount

public void setRetryCount(int retryCount)