Modifier and Type | Method and Description |
---|---|
protected String |
BaseLogger.buildLogMessage(Task task) |
void |
WriteLogger.log(Task task) |
void |
ReadLogger.log(Task task) |
Modifier and Type | Method and Description |
---|---|
Task |
AuditTask.writeTask() |
Modifier and Type | Method and Description |
---|---|
void |
AuditTask.readTask(Task task) |
Modifier and Type | Method and Description |
---|---|
Task |
TaskQueue.take()
Blocks until a task is available
|
Modifier and Type | Method and Description |
---|---|
void |
TaskQueue.deleteTask(Task task)
Deletes a task from the queue.
|
void |
TaskQueue.extendVisibilityTimeout(Task task)
Responsible for robustly extending the visibility timeout of a Task.
|
void |
TaskQueue.put(Task... tasks)
puts multiple tasks on the queue using batch puts if the queue
implementation supports batch puts
|
void |
TaskQueue.put(Task task)
puts a task on the queue
|
void |
TaskQueue.requeue(Task task)
Requeues the task by deleting the task, incrementing the "attempts"
counter, and re-adding back to the queue.
|
Modifier and Type | Method and Description |
---|---|
void |
TaskQueue.put(Set<Task> tasks)
puts multiple tasks on the queue using batch puts if the queue
implementation supports batch puts
|
Modifier and Type | Method and Description |
---|---|
protected Task |
SQSTaskQueue.marshallTask(com.amazonaws.services.sqs.model.Message msg) |
Task |
SQSTaskQueue.take() |
Modifier and Type | Method and Description |
---|---|
void |
SQSTaskQueue.deleteTask(Task task) |
void |
SQSTaskQueue.extendVisibilityTimeout(Task task) |
void |
SQSTaskQueue.put(Task... tasks)
Convenience method that calls put(Set
|
void |
SQSTaskQueue.put(Task task) |
void |
SQSTaskQueue.requeue(Task task) |
protected String |
SQSTaskQueue.unmarshallTask(Task task) |
Modifier and Type | Method and Description |
---|---|
void |
SQSTaskQueue.put(Set<Task> tasks)
Puts multiple tasks on the queue using batch puts.
|
Modifier and Type | Method and Description |
---|---|
Task |
LocalTaskQueue.take() |
Modifier and Type | Method and Description |
---|---|
void |
LocalTaskQueue.deleteTask(Task task) |
void |
LocalTaskQueue.extendVisibilityTimeout(Task task) |
void |
LocalTaskQueue.put(Task... tasks) |
void |
LocalTaskQueue.put(Task task) |
void |
LocalTaskQueue.requeue(Task task) |
Modifier and Type | Method and Description |
---|---|
void |
LocalTaskQueue.put(Set<Task> tasks) |
Modifier and Type | Method and Description |
---|---|
Task |
NoopTaskQueue.take() |
Modifier and Type | Method and Description |
---|---|
void |
NoopTaskQueue.deleteTask(Task task) |
void |
NoopTaskQueue.extendVisibilityTimeout(Task task) |
void |
NoopTaskQueue.put(Task... tasks) |
void |
NoopTaskQueue.put(Task task) |
void |
NoopTaskQueue.requeue(Task task) |
Modifier and Type | Method and Description |
---|---|
void |
NoopTaskQueue.put(Set<Task> tasks) |
Modifier and Type | Method and Description |
---|---|
Task |
TypedTask.writeTask() |
Task |
SpaceCentricTypedTask.writeTask()
Writes all of the information in the SpaceCentricTypedTask into a Task
|
Task |
NoopTask.writeTask() |
Modifier and Type | Method and Description |
---|---|
protected void |
SpaceCentricTypedTask.addProperty(Task task,
String propName,
String propValue) |
void |
TypedTask.readTask(Task task) |
void |
SpaceCentricTypedTask.readTask(Task task)
Reads the information stored in a Task and sets data in the SpaceCentricTypedTask
|
void |
NoopTask.readTask(Task task) |
Copyright © 2009–2014 DuraSpace. All rights reserved.