JavaでSQSの属性を受け取る方法

@iwasaki 35views 更新:2016年6月6日

Javaで受け取る時には明示的に .withMessageAttributeNames をつけて MessageAttributeも取ってくるように指定をします。

      ReceiveMessageResult receiveMessage =
        sqs.receiveMessage(new ReceiveMessageRequest(QueueUrl)
          .withMaxNumberOfMessages(5)
          .withVisibilityTimeout(60 * 5)
          .withWaitTimeSeconds(20)
          .withMessageAttributeNames("All"));

取り出し方は以下のようになります。


List<Message> messages = receiveMessage.getMessages(); for (Message message : messages) { String receiptHandle = message.getReceiptHandle(); try { String key = message.getBody(); Map<String, MessageAttributeValue> messageAttributes = message.getMessageAttributes(); String hogeAttribute = messageAttributes.get("hogeAttribute").getStringValue(); } catch (Exception e) { // } }

ログイン / 新規登録してコメントする

このソースコードをストックして後で利用したり、作業に利用したソースコードをまとめることができます。

こちらもお役に立つかもしれません