MfgLabs/commons-aws

MessageAttributes is missing.

pocman opened this issue · 2 comments

Hi,
I'm trying to use the receiveMessageAsStream.

  val sqs = new AmazonSQSScalaClient(new AmazonSQSAsyncClient(), global)
  val builder = SQSStreamBuilder(sqs)
  val producer_topic = actorSystem.settings.config.getString("sqs.producer_topic")

  val receiver = builder
    .receiveMessageAsStream(producer_topic, autoAck = false)
    .runForeach{ message => println(s"${message.toString}")}

My scala app is receiving :
{ MessageId: e3bf62f1-1bc2-4a1b-be6b-ab1fab563ea7, ReceiptHandle:AQEBLk3OMnrtDs7kRnbxgq4nLHQeJQB1pOsnSkDzwZxBXSBNVvJtbW/Lwk8OL0W+Xg5Zxk+SU59rWNkxBykiyEXA5jWqc9f8EKHMirYMFeLOa77boUUH52bTO6lJHkSz8Y+GgJb+0PvqhCD0D7DQ5EBz7ldjZ1Mrm/W5ilsmitQBLmnIYzeXeB29LR0G+MaFv5TXPnvoKN2ki4x0gG9DY+YC70OCL9LQERj0aqsi2PZlAwEp8QClzkzvFQUSC86QpwVaycjudQNkPxkVOKSCnkvww8/fJbR3kE5L5IP+OTba7S3V+7EE32x3ayH+caBGj3c6ExLDtvrsfkT4Qxpns8+ohO6EYrTu6R5DjGngk6eVXvNOTkdDbwsik8i9+tAQxB3W, MD5OfBody: a391271abf507c9cd1f7068a35010845, Body: pheromone, Attributes: {}, MessageAttributes: {} }

And in the SQS console I have :

Message ID: e3bf62f1-1bc2-4a1b-be6b-ab1fab563ea7
Size: 9 bytes
MD5 of Body: a391271abf507c9cd1f7068a35010845
Sender Account ID: AIDAJP22F6U2PFQ4GLZXY
Sent: 2015-06-16 12:19:50.507 GMT+02:00
First Received: 2015-06-16 12:19:50.507 GMT+02:00
Receive Count: 16
Message Attribute Count: 1

Name Type Value
t Binary DCQWAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA=
Message Attributes Size: 7 bytes
MD5 of Message Attributes: d42512910e23b3aabe049ea19f0029c7

Found the issue :
receiveMessageAsStream methods doesn't call msg.setMessageAttributeNames(attributesNames)
I'll make a pull request.

Closed with #9