@Beta public class SQS extends Object
| Constructor and Description |
|---|
SQS() |
| Modifier and Type | Method and Description |
|---|---|
static com.google.common.collect.FluentIterable<Message> |
receiveAllAtRate(MessageApi api,
int messagesPerPage,
ReceiveMessageOptions options)
Returns an iterable that lazy fetches messages until there are none left.
|
public static com.google.common.collect.FluentIterable<Message> receiveAllAtRate(MessageApi api, int messagesPerPage, ReceiveMessageOptions options)
api - api targeted at the queue in questionmessagesPerPage - how many messages to receive per request (current max: 10)options - controls attributes and visibility optionsCopyright © 2009-2016 The Apache Software Foundation. All Rights Reserved.