From 9b6a4062fff117e70d5b46e44634646b5116691c Mon Sep 17 00:00:00 2001
From: EAMoiseenko <s1lverhron@gmail.com>
Date: Mon, 25 Oct 2021 18:15:33 +0300
Subject: [PATCH] Set to Header only Headers

---
 pkg/amqp-lib/AmqpContext.php | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/pkg/amqp-lib/AmqpContext.php b/pkg/amqp-lib/AmqpContext.php
index 32f60c21b..a57e94339 100644
--- a/pkg/amqp-lib/AmqpContext.php
+++ b/pkg/amqp-lib/AmqpContext.php
@@ -299,14 +299,14 @@ public function getLibChannel(): AMQPChannel
      */
     public function convertMessage(LibAMQPMessage $amqpMessage): InteropAmqpMessage
     {
-        $headers = new AMQPTable($amqpMessage->get_properties());
-        $headers = $headers->getNativeData();
+        $amqpTable = new AMQPTable($amqpMessage->get_properties());
+        $properties = $amqpTable->getNativeData();
 
-        $properties = [];
-        if (isset($headers['application_headers'])) {
-            $properties = $headers['application_headers'];
+        $headers = [];
+        if (isset($properties['application_headers'])) {
+            $headers = $properties['application_headers'];
         }
-        unset($headers['application_headers']);
+        unset($properties['application_headers']);
 
         $message = new AmqpMessage($amqpMessage->getBody(), $properties, $headers);
         $message->setDeliveryTag((int) $amqpMessage->delivery_info['delivery_tag']);