diff --git a/pkg/amqp-ext/AmqpSubscriptionConsumer.php b/pkg/amqp-ext/AmqpSubscriptionConsumer.php
index 4b03f6bbb..08a3df1c6 100644
--- 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);
         } catch (\AMQPQueueException $e) {
             if ('Consumer timeout exceed' == $e->getMessage()) {
                 return;