diff --git a/src/Consumer/AMQPEntryConsumer.php b/src/Consumer/AMQPEntryConsumer.php
index cd51b42f8..f74f78bd0 100644
--- a/src/Consumer/AMQPEntryConsumer.php
+++ b/src/Consumer/AMQPEntryConsumer.php
@@ -9,6 +9,6 @@ class AMQPEntryConsumer extends AbstractConsumer implements ConsumerInterface
 {
     public function execute(AMQPMessage $msg)
     {
-        return $this->handleMessage($msg->body);
+        return $this->handleMessage($msg->getBody());
     }
 }
diff --git a/src/Consumer/RabbitMQConsumerTotalProxy.php b/src/Consumer/RabbitMQConsumerTotalProxy.php
index 4cce92c1b..41e4fd491 100644
--- a/src/Consumer/RabbitMQConsumerTotalProxy.php
+++ b/src/Consumer/RabbitMQConsumerTotalProxy.php
@@ -115,6 +115,6 @@ class RabbitMQConsumerTotalProxy
             return 0;
         }
 
-        return $message->delivery_info['message_count'] + 1;
+        return $message->getMessageCount() + 1;
     }
 }