diff --git a/AmqpSubscriptionConsumer.php b/AmqpSubscriptionConsumer.php
index <HASH>..<HASH> 100644
--- a/AmqpSubscriptionConsumer.php
+++ b/AmqpSubscriptionConsumer.php
@@ -29,6 +29,8 @@ class AmqpSubscriptionConsumer implements PsrSubscriptionConsumer
     public function __construct(AmqpContext $context)
     {
         $this->context = $context;
+
+        $this->subscribers = [];
     }
 
     /**
move subscription logic of amqplib and amqpext to separate classes.