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