From 62370e4235979df474d8f4e9c5d63eae3a144887 Mon Sep 17 00:00:00 2001 From: Dariusz Gafka Date: Tue, 1 Sep 2020 14:24:09 +0200 Subject: [PATCH] Solves binding Headers Exchange with Queue using custom arguments --- pkg/amqp-lib/AmqpContext.php | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/amqp-lib/AmqpContext.php b/pkg/amqp-lib/AmqpContext.php index 3628b09c9..32f60c21b 100644 --- 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()) ); } }