Fix for consumer with empty queue not handling SIGTERM/SIGINT (#430)

tommygnr · skafandri · commit 20c2f4a28394 · 2017-01-30T07:28:22.000+02:00
This applies the change made in d3fef7f to the MultipleConsumer Refs #352 #178 #260
diff --git 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);
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -102,7 +102,7 @@ public function processQueueMessage($queueName, AMQPMessage $msg)`
`102`	`102`	`public function stopConsuming()`
`103`	`103`	`{`
`104`	`104`	`foreach ($this->queues as $name => $options) {`
`105`		`- $this->getChannel()->basic_cancel($this->getQueueConsumerTag($name));`
	`105`	`+ $this->getChannel()->basic_cancel($this->getQueueConsumerTag($name), false, true);`
`106`	`106`	`}`
`107`	`107`	`}`
`108`	`108`