Package | Description |
---|---|
org.jclouds.sqs |
This package contains an Amazon SQS api implemented by
HttpCommandExecutorService commands. |
org.jclouds.sqs.domain | |
org.jclouds.sqs.features | |
org.jclouds.sqs.xml |
Modifier and Type | Method and Description |
---|---|
static com.google.common.collect.FluentIterable<Message> |
SQS.receiveAllAtRate(MessageApi api,
int messagesPerPage,
ReceiveMessageOptions options)
Returns an iterable that lazy fetches messages until there are none left.
|
Modifier and Type | Method and Description |
---|---|
Message |
Message.Builder.build() |
Modifier and Type | Method and Description |
---|---|
Message.Builder |
Message.Builder.fromMessage(Message in) |
Modifier and Type | Method and Description |
---|---|
Message |
MessageApi.receive()
The ReceiveMessage action retrieves one or more messages from the
specified queue.
|
Message |
MessageApi.receive(ReceiveMessageOptions options)
same as
#receive(URI) except you can provide options like
VisibilityTimeout parameter in your request, which will be applied to the
messages that SQS returns in the response. |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<Message> |
MessageAsyncApi.receive() |
com.google.common.util.concurrent.ListenableFuture<? extends com.google.common.collect.FluentIterable<? extends Message>> |
MessageAsyncApi.receive(int max) |
com.google.common.collect.FluentIterable<Message> |
MessageApi.receive(int max)
same as
#receive(URI) except you can receive multiple messages. |
com.google.common.util.concurrent.ListenableFuture<? extends com.google.common.collect.FluentIterable<? extends Message>> |
MessageAsyncApi.receive(int max,
ReceiveMessageOptions options) |
com.google.common.collect.FluentIterable<Message> |
MessageApi.receive(int max,
ReceiveMessageOptions options)
same as
#receive(URI, int) except you can provide options like
VisibilityTimeout parameter in your request, which will be applied to the
messages that SQS returns in the response. |
com.google.common.util.concurrent.ListenableFuture<? extends Message> |
MessageAsyncApi.receive(ReceiveMessageOptions options) |
static com.google.common.base.Function<Message,String> |
Messages.toReceiptHandle() |
Modifier and Type | Method and Description |
---|---|
Message |
MessageHandler.getResult() |
Modifier and Type | Method and Description |
---|---|
com.google.common.collect.FluentIterable<Message> |
ReceiveMessageResponseHandler.getResult() |
Copyright © 2009-2013 jclouds. All Rights Reserved.