call signal_dispatch in queue loop

Alessandro Chitolina · Alessandro Chitolina · commit 75087789e190 · 2016-09-14T15:06:53.000+02:00
diff --git a/src/Queue/AmqpLibQueue.php b/src/Queue/AmqpLibQueue.php
@@ -88,6 +88,7 @@ public function runLoop()
         while (! $this->stopped) {
             try {
                 $this->channel->wait(null, true, 1);
+                pcntl_signal_dispatch();
             } catch (AMQPTimeoutException $ex) {
             } catch (AMQPIOWaitException $ex) {
             }

Original file line number	Diff line number	Diff line change
`@@ -88,6 +88,7 @@ public function runLoop()`
`88`	`88`	`while (! $this->stopped) {`
`89`	`89`	`try {`
`90`	`90`	`$this->channel->wait(null, true, 1);`
	`91`	`+ pcntl_signal_dispatch();`
`91`	`92`	`} catch (AMQPTimeoutException $ex) {`
`92`	`93`	`} catch (AMQPIOWaitException $ex) {`
`93`	`94`	`}`