Dispatch unix signals for consumer commands

videlalvaro · Aug 17, 2012 · 4690dc8 · 4690dc8
1 parent 0f712e6
commit 4690dc8
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/Command/BaseConsumerCommand.php b/Command/BaseConsumerCommand.php
@@ -61,6 +61,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
         if($signals){
             if(extension_loaded('pcntl')){
                 pcntl_signal(SIGTERM, array(&$this, 'stopConsumer'));
+                pcntl_signal(SIGINT, array(&$this, 'stopConsumer'));
                 pcntl_signal(SIGHUP, array(&$this, 'restartConsumer'));
             }else{
                 throw new \InvalidArgumentException("The -s option can be used, if pcntl extension installed");

diff --git a/RabbitMq/BaseConsumer.php b/RabbitMq/BaseConsumer.php
@@ -58,7 +58,7 @@ protected function maybeStopConsumer()
         if(extension_loaded('pcntl')) {
             pcntl_signal_dispatch();
         }
-        
+
         if($this->forceStop || ($this->consumed == $this->target && $this->target > 0)) {
             $this->stopConsuming();
         } else {