Constructor and Description |
---|
LocalTaskQueue() |
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.
|
long |
getCompletedCount() |
int |
getInprocessCount() |
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
|
public String getName()
TaskQueue
public void put(Task task)
TaskQueue
public void put(Task... tasks)
TaskQueue
public void put(Set<Task> tasks)
TaskQueue
public Task take() throws TimeoutException
TaskQueue
take
in interface TaskQueue
TimeoutException
public void extendVisibilityTimeout(Task task) throws TaskNotFoundException
TaskQueue
extendVisibilityTimeout
in interface TaskQueue
TaskNotFoundException
public void deleteTask(Task task) throws TaskNotFoundException
TaskQueue
deleteTask
in interface TaskQueue
TaskNotFoundException
public Integer size()
public int getInprocessCount()
public long getCompletedCount()
public Integer sizeIncludingInvisibleAndDelayed()
sizeIncludingInvisibleAndDelayed
in interface TaskQueue
Copyright © 2009–2014 DuraSpace. All rights reserved.