Solves binding Headers Exchange with Queue using custom arguments

dgafka · dgafka · commit 62370e423597 · 2020-09-01T14:24:09.000+02:00
diff --git a/pkg/amqp-lib/AmqpContext.php b/pkg/amqp-lib/AmqpContext.php
@@ -220,7 +220,7 @@ public function bind(InteropAmqpBind $bind): void
                 $bind->getTarget()->getTopicName(),
                 $bind->getRoutingKey(),
                 (bool) ($bind->getFlags() & InteropAmqpBind::FLAG_NOWAIT),
-                $bind->getArguments()
+                new AMQPTable($bind->getArguments())
             );
         // bind exchange to queue
         } else {
@@ -229,7 +229,7 @@ public function bind(InteropAmqpBind $bind): void
                 $bind->getSource()->getTopicName(),
                 $bind->getRoutingKey(),
                 (bool) ($bind->getFlags() & InteropAmqpBind::FLAG_NOWAIT),
-                $bind->getArguments()
+                new AMQPTable($bind->getArguments())
             );
         }
     }
