Merge pull request #373 from alexbumbacea/remove-exit

#372 - removed exit(), also considering #352

Author: skafandri

Command/BaseConsumerCommand.php

@@ -28,7 +28,6 @@ public function stopConsumer()
                 $this->consumer->stopConsuming();
             } catch (AMQPTimeoutException $e) {}
         }
-        exit();
     }
 
     public function restartConsumer()

RabbitMq/Consumer.php

@@ -45,7 +45,9 @@ public function consume($msgAmount)
 
         while (count($this->getChannel()->callbacks)) {
             $this->maybeStopConsumer();
-            $this->getChannel()->wait(null, false, $this->getIdleTimeout());
+            if (!$this->forceStop) {
+                $this->getChannel()->wait(null, false, $this->getIdleTimeout());
+            }
         }
     }