Skip to content

Commit 61177d7

Browse files
authored
Merge pull request #1087 from SimplyCodedSoftware/master
Solves binding Headers Exchange with Queue using custom arguments
2 parents fc21c31 + 62370e4 commit 61177d7

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pkg/amqp-lib/AmqpContext.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,7 @@ public function bind(InteropAmqpBind $bind): void
220220
$bind->getTarget()->getTopicName(),
221221
$bind->getRoutingKey(),
222222
(bool) ($bind->getFlags() & InteropAmqpBind::FLAG_NOWAIT),
223-
$bind->getArguments()
223+
new AMQPTable($bind->getArguments())
224224
);
225225
// bind exchange to queue
226226
} else {
@@ -229,7 +229,7 @@ public function bind(InteropAmqpBind $bind): void
229229
$bind->getSource()->getTopicName(),
230230
$bind->getRoutingKey(),
231231
(bool) ($bind->getFlags() & InteropAmqpBind::FLAG_NOWAIT),
232-
$bind->getArguments()
232+
new AMQPTable($bind->getArguments())
233233
);
234234
}
235235
}

0 commit comments

Comments
 (0)