Fix for consumer with empty queue not being able to handle SIGTERM and SIGINT

Eligijus Vitkauskas · Eligijus Vitkauskas · commit d3fef7fde584 · 2016-12-06T16:46:18.000+02:00
This solution still dispatches "console.terminate" as requested in #372 Fix for #352 #178 #260
diff --git a/RabbitMq/BaseConsumer.php b/RabbitMq/BaseConsumer.php
@@ -34,9 +34,15 @@ public function start($msgAmount = 0)
         }
     }
 
+    /**
+     * Tell the server you are going to stop consuming.
+     *
+     * It will finish up the last message and not send you any more.
+     */
     public function stopConsuming()
     {
-        $this->getChannel()->basic_cancel($this->getConsumerTag());
+        // This gets stuck and will not exit without the last two parameters set.
+        $this->getChannel()->basic_cancel($this->getConsumerTag(), false, true);
     }
 
     protected function setupConsumer()

Original file line number	Diff line number	Diff line change
`@@ -34,9 +34,15 @@ public function start($msgAmount = 0)`
`34`	`34`	`}`
`35`	`35`	`}`
`36`	`36`
	`37`	`+ /**`
	`38`	`+ * Tell the server you are going to stop consuming.`
	`39`	`+ *`
	`40`	`+ * It will finish up the last message and not send you any more.`
	`41`	`+ */`
`37`	`42`	`public function stopConsuming()`
`38`	`43`	`{`
`39`		`- $this->getChannel()->basic_cancel($this->getConsumerTag());`
	`44`	`+ // This gets stuck and will not exit without the last two parameters set.`
	`45`	`+ $this->getChannel()->basic_cancel($this->getConsumerTag(), false, true);`
`40`	`46`	`}`
`41`	`47`
`42`	`48`	`protected function setupConsumer()`