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());
                     }