Skip to content

Commit

Permalink
Change the deprecated method to a getter method.
Browse files Browse the repository at this point in the history
  • Loading branch information
DikoIbragimov committed Dec 7, 2024
1 parent e70aba5 commit 4c4e44b
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/ExistingMessagesConsumer.php
Original file line number Diff line number Diff line change
Expand Up @@ -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());
}
Expand Down

0 comments on commit 4c4e44b

Please sign in to comment.