diff --git a/RabbitMq/MultipleConsumer.php b/RabbitMq/MultipleConsumer.php index 79dbf5ea..083431d3 100644 --- a/RabbitMq/MultipleConsumer.php +++ b/RabbitMq/MultipleConsumer.php @@ -102,7 +102,7 @@ public function processQueueMessage($queueName, AMQPMessage $msg) public function stopConsuming() { foreach ($this->queues as $name => $options) { - $this->getChannel()->basic_cancel($this->getQueueConsumerTag($name)); + $this->getChannel()->basic_cancel($this->getQueueConsumerTag($name), false, true); } }