From 6cd8ad6f8b0bde40b71094593990eead3ef0281d Mon Sep 17 00:00:00 2001 From: Tom Corrigan Date: Mon, 30 Jan 2017 13:47:19 +1100 Subject: [PATCH] Fix for consumer with empty queue not handling SIGTERM/SIGINT This applies the change made in d3fef7fde58424af42d0a6f8e844b7b99fbe5840 to the MultipleConsumer Refs #352 #178 #260 --- RabbitMq/MultipleConsumer.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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); } }