From 4c4e44bd6324823c36059f18ec519b2420e8ba6d Mon Sep 17 00:00:00 2001 From: uzdevid Date: Sat, 7 Dec 2024 23:29:28 +0500 Subject: [PATCH] Change the deprecated method to a getter method. --- src/ExistingMessagesConsumer.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/ExistingMessagesConsumer.php b/src/ExistingMessagesConsumer.php index f01f97a..37d361b 100644 --- a/src/ExistingMessagesConsumer.php +++ b/src/ExistingMessagesConsumer.php @@ -38,7 +38,7 @@ public function consume(callable $callback): void false, function (AMQPMessage $amqpMessage) use ($callback): void { try { - $message = $this->serializer->unserialize($amqpMessage->body); + $message = $this->serializer->unserialize($amqpMessage->getBody()); if ($this->messageConsumed = $callback($message)) { $this->channel->basic_ack($amqpMessage->getDeliveryTag()); }