diff --git a/pkg/amqp-bunny/AmqpContext.php b/pkg/amqp-bunny/AmqpContext.php
index 09c810bca..a519227ca 100644
--- a/pkg/amqp-bunny/AmqpContext.php
+++ b/pkg/amqp-bunny/AmqpContext.php
@@ -388,7 +388,7 @@ public function consume($timeout = 0)
             throw new \LogicException('There is no subscribers. Consider calling basicConsumeSubscribe before consuming');
         }
 
-        $this->getBunnyChannel()->getClient()->run($timeout / 1000);
+        $this->getBunnyChannel()->getClient()->run(0 !== $timeout ? $timeout / 1000 : null);
     }
 
     /**