Skip to content

Commit adb8986

Browse files
committed
Remove queue name from message in publish method in IronMqProvider fix #53
1 parent 27786ad commit adb8986

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

src/Provider/IronMqProvider.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ public function publish(array $message, array $options = [])
140140

141141
$result = $this->ironmq->postMessage(
142142
$this->getNameWithPrefix(),
143-
json_encode([$this->name => $message]),
143+
json_encode($message),
144144
[
145145
'timeout' => $options['message_timeout'],
146146
'delay' => $options['message_delay'],
@@ -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 = json_decode($message->body);
186+
$body = $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, json_encode($body->{$this->name}), $metadata);
193+
$message = new Message($id, $body, $metadata);
194194

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

0 commit comments

Comments
 (0)