diff --git a/AmqpSubscriptionConsumer.php b/AmqpSubscriptionConsumer.php
index 08a3df1..ae74704 100644
--- a/AmqpSubscriptionConsumer.php
+++ b/AmqpSubscriptionConsumer.php
@@ -96,7 +96,7 @@ public function subscribe(Consumer $consumer, callable $callback): void
         $extQueue = new \AMQPQueue($this->context->getExtChannel());
         $extQueue->setName($consumer->getQueue()->getQueueName());
 
-        $extQueue->consume(null, Flags::convertConsumerFlags($consumer->getFlags()), $consumer->getConsumerTag());
+        $extQueue->consume(null, Flags::convertConsumerFlags($consumer->getFlags()), $consumer->getConsumerTag() ?? '');
 
         $consumerTag = $extQueue->getConsumerTag();
         $consumer->setConsumerTag($consumerTag);
diff --git a/composer.json b/composer.json
index 57fb5b2..e0e327b 100644
--- a/composer.json
+++ b/composer.json
@@ -1,5 +1,5 @@
 {
-    "name": "enqueue/amqp-ext",
+    "name": "dimanzver/amqp-ext",
     "type": "library",
     "description": "Message Queue Amqp Transport",
     "keywords": ["messaging", "queue", "amqp"],
@@ -8,7 +8,7 @@
     "require": {
         "php": "^7.4|^8.0",
         "ext-amqp": "^1.9.3",
-        "queue-interop/amqp-interop": "^0.8.2",
+        "dimanzver/amqp-interop": "^0.8.3",
         "queue-interop/queue-interop": "^0.8",
         "enqueue/amqp-tools": "^0.10"
     },