Skip to content

Commit 27786ad

Browse files
author
Alexei Plotnikov
committed
Fix #53 IronMqProvider return message's body with name of queue
1 parent 27d70f3 commit 27786ad

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

src/Provider/IronMqProvider.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -183,14 +183,14 @@ public function receive(array $options = [])
183183
// Convert to Message Class
184184
foreach ($messages as &$message) {
185185
$id = $message->id;
186-
$body = $message->body;
186+
$body = json_decode($message->body);
187187
$metadata = [
188188
'timeout' => $message->timeout,
189189
'reserved_count' => $message->reserved_count,
190190
'push_status' => $message->push_status
191191
];
192192

193-
$message = new Message($id, $body, $metadata);
193+
$message = new Message($id, json_encode($body->{$this->name}), $metadata);
194194

195195
$this->log(200, "Message has been received.", ['message_id' => $id]);
196196
}

tests/MockClient/IronMqMockClient.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ public function getMessages($queue, $count, $timeout)
7474
{
7575
$response = new \stdClass;
7676
$response->id = 123;
77-
$response->body = "test";
77+
$response->body = '{"test":{"foo":"bar"}}';
7878
$response->timeout = 60;
7979
$response->reserved_count = 1;
8080
$response->push_status = new \stdClass;

0 commit comments

Comments
 (0)