Remove queue name from message in publish method in IronMqProvider fix …

…uecode#53
pasxel · Nov 30, 2014 · adb8986 · adb8986
1 parent 27786ad
commit adb8986
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/Provider/IronMqProvider.php b/src/Provider/IronMqProvider.php
@@ -140,7 +140,7 @@ public function publish(array $message, array $options = [])
 
         $result = $this->ironmq->postMessage(
             $this->getNameWithPrefix(),
-            json_encode([$this->name => $message]),
+            json_encode($message),
             [
                 'timeout'       => $options['message_timeout'],
                 'delay'         => $options['message_delay'],
@@ -183,14 +183,14 @@ public function receive(array $options = [])
         // Convert to Message Class
         foreach ($messages as &$message) {
             $id         = $message->id;
-            $body       = json_decode($message->body);
+            $body       = $message->body;
             $metadata   = [
                 'timeout'           => $message->timeout,
                 'reserved_count'    => $message->reserved_count,
                 'push_status'       => $message->push_status
             ];
 
-            $message = new Message($id, json_encode($body->{$this->name}), $metadata);
+            $message = new Message($id, $body, $metadata);
 
             $this->log(200, "Message has been received.", ['message_id' => $id]);
         }