SQS FIFO 使用MessageGroupId接收消息

Question

如何使用 messagegroupid 参数仅接收标记有我需要的 ID 的队列消息？

我一直在尝试使用下面的行来检索，但它也始终会收到来自其他组 ID 的所有队列消息。

List<Message> messages = sqs.receiveMessage(receiveMessageRequest.withAttributeNames("MessageGroupId")).getMessages();

正确的做法应该是什么？

Answer 1

ReceiveMessageRequest不用于基于消息属性的过滤。如果您查看ReceiveMessageRequest.html.withAttributeNames()的文档，它会显示：

需要与每条消息一起返回的属性列表。

一般来说，您无法过滤从 SQS 返回的消息。您可以限制数量，但不能说“给我所有与此模式匹配的消息”。