replace amqp-lib deprecated public property with getters

Author: ramunasd

pkg/amqp-lib/AmqpContext.php

@@ -309,9 +309,9 @@ public function convertMessage(LibAMQPMessage $amqpMessage): InteropAmqpMessage
         unset($headers['application_headers']);
 
         $message = new AmqpMessage($amqpMessage->getBody(), $properties, $headers);
-        $message->setDeliveryTag((int) $amqpMessage->delivery_info['delivery_tag']);
-        $message->setRedelivered($amqpMessage->delivery_info['redelivered']);
-        $message->setRoutingKey($amqpMessage->delivery_info['routing_key']);
+        $message->setDeliveryTag((int) $amqpMessage->getDeliveryTag());
+        $message->setRedelivered($amqpMessage->isRedelivered());
+        $message->setRoutingKey($amqpMessage->getRoutingKey());
 
         return $message;
     }

pkg/amqp-lib/AmqpSubscriptionConsumer.php

@@ -102,13 +102,13 @@ public function subscribe(Consumer $consumer, callable $callback): void
 
         $libCallback = function (LibAMQPMessage $message) {
             $receivedMessage = $this->context->convertMessage($message);
-            $receivedMessage->setConsumerTag($message->delivery_info['consumer_tag']);
+            $receivedMessage->setConsumerTag($message->getConsumerTag());
 
             /**
              * @var AmqpConsumer
              * @var callable     $callback
              */
-            list($consumer, $callback) = $this->subscribers[$message->delivery_info['consumer_tag']];
+            list($consumer, $callback) = $this->subscribers[$message->getConsumerTag()];
 
             if (false === call_user_func($callback, $receivedMessage, $consumer)) {
                 throw new StopBasicConsumptionException();

pkg/amqp-lib/Tests/AmqpConsumerTest.php

@@ -112,10 +112,7 @@ public function testOnRejectShouldRejectMessage()
     public function testShouldReturnMessageOnReceiveNoWait()
     {
         $libMessage = new \PhpAmqpLib\Message\AMQPMessage('body');
-        $libMessage->delivery_info['delivery_tag'] = 'delivery-tag';
-        $libMessage->delivery_info['routing_key'] = 'routing-key';
-        $libMessage->delivery_info['redelivered'] = true;
-        $libMessage->delivery_info['routing_key'] = 'routing-key';
+        $libMessage->setDeliveryInfo('delivery-tag', true, '', 'routing-key');
 
         $message = new AmqpMessage();
 
@@ -149,9 +146,7 @@ public function testShouldReturnMessageOnReceiveNoWait()
     public function testShouldReturnMessageOnReceiveWithReceiveMethodBasicGet()
     {
         $libMessage = new \PhpAmqpLib\Message\AMQPMessage('body');
-        $libMessage->delivery_info['delivery_tag'] = 'delivery-tag';
-        $libMessage->delivery_info['routing_key'] = 'routing-key';
-        $libMessage->delivery_info['redelivered'] = true;
+        $libMessage->setDeliveryInfo('delivery-tag', true, '', 'routing-key');
 
         $message = new AmqpMessage();
 

pkg/amqp-lib/Tests/Spec/AmqpSubscriptionConsumerConsumeUntilUnsubscribedTest.php

@@ -13,7 +13,7 @@
  */
 class AmqpSubscriptionConsumerConsumeUntilUnsubscribedTest extends SubscriptionConsumerConsumeUntilUnsubscribedSpec
 {
-    protected function tearDown()
+    protected function tearDown(): void
     {
         if ($this->subscriptionConsumer) {
             $this->subscriptionConsumer->unsubscribeAll();

pkg/amqp-lib/composer.json

@@ -7,7 +7,7 @@
     "license": "MIT",
     "require": {
         "php": "^7.1.3",
-        "php-amqplib/php-amqplib": "^2.10",
+        "php-amqplib/php-amqplib": "^3.2",
         "queue-interop/amqp-interop": "^0.8",
         "queue-interop/queue-interop": "^0.7|^0.8",
         "enqueue/amqp-tools": "^0.9"