Package | Description |
---|---|
org.duracloud.common.queue | |
org.duracloud.common.queue.aws | |
org.duracloud.common.queue.local | |
org.duracloud.common.queue.noop |
Modifier and Type | Method and Description |
---|---|
Task |
TaskQueue.take()
Blocks until a task is available
|
Set<Task> |
TaskQueue.take(int maxTasks)
Take a max of specified number of tasks.
|
Modifier and Type | Method and Description |
---|---|
Task |
SQSTaskQueue.take() |
Set<Task> |
SQSTaskQueue.take(int maxTasks) |
Modifier and Type | Method and Description |
---|---|
Task |
LocalTaskQueue.take() |
Set<Task> |
LocalTaskQueue.take(int maxTasks) |
Modifier and Type | Method and Description |
---|---|
Task |
NoopTaskQueue.take() |
Set<Task> |
NoopTaskQueue.take(int maxTasks) |
Copyright © 2009–2016 DuraSpace. All rights reserved.