From 36d201cbd44eb82a5e0a595ddeb7aefd37786a8c Mon Sep 17 00:00:00 2001 From: Witold Wasiczko Date: Wed, 8 Jun 2022 10:56:47 +0200 Subject: [PATCH] Ensure pass consumer tag as string to bunny amqp (fixes 8.1 compatibility) --- pkg/amqp-bunny/AmqpSubscriptionConsumer.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/amqp-bunny/AmqpSubscriptionConsumer.php b/pkg/amqp-bunny/AmqpSubscriptionConsumer.php index 4fff4f8ab..b36bcd949 100644 --- a/pkg/amqp-bunny/AmqpSubscriptionConsumer.php +++ b/pkg/amqp-bunny/AmqpSubscriptionConsumer.php @@ -88,7 +88,7 @@ public function subscribe(Consumer $consumer, callable $callback): void $frame = $this->context->getBunnyChannel()->consume( $bunnyCallback, $consumer->getQueue()->getQueueName(), - $consumer->getConsumerTag(), + $consumer->getConsumerTag() ?? '', (bool) ($consumer->getFlags() & InteropAmqpConsumer::FLAG_NOLOCAL), (bool) ($consumer->getFlags() & InteropAmqpConsumer::FLAG_NOACK), (bool) ($consumer->getFlags() & InteropAmqpConsumer::FLAG_EXCLUSIVE),