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),