public interface TaskQueue
Modifier and Type | Method and Description |
---|---|
void |
deleteTask(Task task)
Deletes a task from the queue.
|
void |
extendVisibilityTimeout(Task task)
Responsible for robustly extending the visibility timeout of a Task.
|
String |
getName()
A name identifying the queue used for logging and analysis purposes.
|
void |
put(Set<Task> tasks)
puts multiple tasks on the queue using batch puts if the queue
implementation supports batch puts
|
void |
put(Task... tasks)
puts multiple tasks on the queue using batch puts if the queue
implementation supports batch puts
|
void |
put(Task task)
puts a task on the queue
|
void |
requeue(Task task)
Requeues the task by deleting the task, incrementing the "attempts"
counter, and re-adding back to the queue.
|
Integer |
size() |
Integer |
sizeIncludingInvisibleAndDelayed() |
Task |
take()
Blocks until a task is available
|
String getName()
void put(Task task)
task
- void put(Task... tasks)
tasks
- void put(Set<Task> tasks)
tasks
- Task take() throws TimeoutException
TimeoutException
void extendVisibilityTimeout(Task task) throws TaskNotFoundException
task
- TaskNotFoundException
void deleteTask(Task task) throws TaskNotFoundException
task
- TaskNotFoundException
Integer size()
Integer sizeIncludingInvisibleAndDelayed()
void requeue(Task task)
task
- Copyright © 2009–2014 DuraSpace. All rights reserved.