| 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.