diff --git a/RabbitMq/BatchConsumer.php b/RabbitMq/BatchConsumer.php index b32d8fae..ce48ad04 100644 --- a/RabbitMq/BatchConsumer.php +++ b/RabbitMq/BatchConsumer.php @@ -292,7 +292,7 @@ public function stopConsuming() $this->batchConsume(); } - $this->getChannel()->basic_cancel($this->getConsumerTag()); + $this->getChannel()->basic_cancel($this->getConsumerTag(), false, true); } /**