Merge pull request #56 from Enoptea/fix/handle-message-new-format

Handle message new format in previous release for php 7.0.
zf-fr · Nov 6, 2017 · 79cde0a · 79cde0a
2 parents 730086d + 8b5df79
commit 79cde0a
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/MessageQueue/MessageQueue.php b/src/MessageQueue/MessageQueue.php
@@ -109,6 +109,12 @@ private function doFlush(bool $async)
             foreach ($messagesToPush as $key => $message) {
                 $messageParameters = [
                     'Id'           => $key, // Identifier of the message in the batch
+                    'MessageAttributes' => [
+                        'Name' => [
+                            'DataType'    => 'String',
+                            'StringValue' => $message['body']['name'],
+                        ],
+                    ],
                     'MessageBody'  => json_encode($message['body'], self::DEFAULT_JSON_FLAGS),
                     'DelaySeconds' => $message['options']['delay_seconds'] ?? null
                 ];