Merge pull request #54 from pasxel/master

Fix #53 IronMqProvider return message's body with name of queue
uecode · Dec 2, 2014 · a176586 · a176586
2 parents 27d70f3 + adb8986
commit a176586
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 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'],

diff --git a/tests/MockClient/IronMqMockClient.php b/tests/MockClient/IronMqMockClient.php
@@ -74,7 +74,7 @@ public function getMessages($queue, $count, $timeout)
     {
         $response                   = new \stdClass;
         $response->id               = 123;
-        $response->body             = "test";
+        $response->body             = '{"test":{"foo":"bar"}}';
         $response->timeout          = 60;
         $response->reserved_count   = 1;
         $response->push_status      = new \stdClass;