Amazon AWS SQS Java-属性为空

Question

我正在尝试从正在处理的每个消息中提取AWS SQS消息属性。我已经验证了属性在那里并且所有的东西都拼写正确：name：RequestId value：thisistherequestid

我收到的信息是这样的：

messages = sqs.receiveMessage(request.withQueueUrl(queueUrl).withAttributeNames("All")).getMessages()

我还尝试过：

messages = sqs.receiveMessage(request.withQueueUrl(queueUrl).withAttributeNames("RequestId")).getMessages()

        for (Message m : messages) {
            Map<String, MessageAttributeValue> attributeValues = new HashMap<String, MessageAttributeValue>();
            attributeValues = m.getMessageAttributes();
            System.out.println("Attribute Values ===>  " + attributeValues.get("RequestId").getStringValue());

        for (Message m : messages) {
            Map<String, String> attributeValues = new HashMap<String, String>();
            attributeValues = m.getAttributes();
            System.out.println("Attribute Values ===>  " + attributeValues.get("RequestId"));

            attributeValues = m.getMessageAttributes();
            System.out.println("Attribute Values ===>  " + attributeValues);

Answer 1

您设置的是SQS中的消息属性。因此，在检索时，您必须使用下面的代码。

messages = sqs.receiveMessage(request.withQueueUrl(queueUrl).withMessageAttributeNames("RequestId")).getMessages()

这将获取名为requestId的消息属性