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