Deprecated: AMQPQueue::consume(): Passing null to parameter php-enqueue#3 ($consumer_tag) of type string is deprecated

iborysenko · web-flow · commit a2acdc607a4e · 2022-02-02T12:14:01.000+02:00
Fixed Deprecation
diff --git a/pkg/amqp-ext/AmqpSubscriptionConsumer.php b/pkg/amqp-ext/AmqpSubscriptionConsumer.php
@@ -68,7 +68,7 @@ public function consume(int $timeout = 0): void
                 } finally {
                     $extConnection->setReadTimeout($consumeTimeout);
                 }
-            }, AMQP_JUST_CONSUME);
+            }, AMQP_JUST_CONSUME, $consumer->getConsumerTag());
         } catch (\AMQPQueueException $e) {
             if ('Consumer timeout exceed' == $e->getMessage()) {
                 return;

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ public function consume(int $timeout = 0): void`
`68`	`68`	`} finally {`
`69`	`69`	`$extConnection->setReadTimeout($consumeTimeout);`
`70`	`70`	`}`
`71`		`- }, AMQP_JUST_CONSUME);`
	`71`	`+ }, AMQP_JUST_CONSUME, $consumer->getConsumerTag());`
`72`	`72`	`} catch (\AMQPQueueException $e) {`
`73`	`73`	`if ('Consumer timeout exceed' == $e->getMessage()) {`
`74`	`74`	`return;`