java - SQS FIFO 使用 MessageGroupId 接收消息

Question

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

我一直在尝试使用下面的行进行检索，但它也将始终接收来自其他组 ID 的所有队列消息。
List<Message> messages = sqs.receiveMessage(receiveMessageRequest.withAttributeNames("MessageGroupId")).getMessages();
正确的做法应该是什么？

Answer 1

ReceiveMessageRequest不用于基于消息属性的过滤。如果您查看 ReceiveMessageRequest.html.withAttributeNames() 的文档它说:

A list of attributes that need to be returned along with each message.

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