public class AbstractErrorQueuedTaskQueue extends AbstractTaskQueue implements TaskQueueWithErrorQueue
| Modifier and Type | Class and Description |
|---|---|
static class |
AbstractErrorQueuedTaskQueue.TaskDecorator |
buffer| Constructor and Description |
|---|
AbstractErrorQueuedTaskQueue(TaskQueue errorQueue,
FifoBuffer<Task> buffer) |
| 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) |
clear, getFlushStarted, getQueue, getTasks, isFlushing, sizeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitclear, getFlushStarted, getTasks, isFlushing, sizepublic AbstractErrorQueuedTaskQueue(TaskQueue errorQueue, FifoBuffer<Task> buffer)
public void flush()
TaskQueueflush in interface TaskQueueflush in class AbstractTaskQueueprotected void handleException(Task task, Exception rootException)
handleException in class AbstractTaskQueuepublic void addTask(Task task)
TaskQueueaddTask in interface TaskQueueaddTask in class AbstractTaskQueuetask - the task to addpublic TaskQueue getErrorQueue()
getErrorQueue in interface TaskQueueWithErrorQueuepublic int getRetryCount()
public void setRetryCount(int retryCount)
Copyright © 2016 Atlassian. All rights reserved.