У меня есть несколько сообщений в SQS. Следующий код всегда возвращает только один, даже если есть десятки видимых (не в полете). setMaxNumberOfMessages Я думал, что позволит несколько раз потреблять сразу. Не понял ли я это?
CreateQueueRequest createQueueRequest = new CreateQueueRequest().withQueueName(queueName);
String queueUrl = sqs.createQueue(createQueueRequest).getQueueUrl();
ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest(queueUrl);
receiveMessageRequest.setMaxNumberOfMessages(10);
List<Message> messages = sqs.receiveMessage(receiveMessageRequest).getMessages();
for (Message message : messages) {
// i'm a message from SQS
}
Я также пробовал использовать withMaxNumberOfMessages без такой удачи:
receiveMessageRequest.withMaxNumberOfMessages(10);
Как узнать, есть ли сообщения в очереди? Более 1?
Set<String> attrs = new HashSet<String>();
attrs.add("ApproximateNumberOfMessages");
CreateQueueRequest createQueueRequest = new CreateQueueRequest().withQueueName(queueName);
GetQueueAttributesRequest a = new GetQueueAttributesRequest().withQueueUrl(sqs.createQueue(createQueueRequest).getQueueUrl()).withAttributeNames(attrs);
Map<String,String> result = sqs.getQueueAttributes(a).getAttributes();
int num = Integer.parseInt(result.get("ApproximateNumberOfMessages"));
Вышеуказанное всегда выполняется раньше и дает мне int
, который является > 1
Спасибо за ваш вклад