@@ -52,8 +52,8 @@ discard block |
||
52 | 52 | ->addOption('connection', 'c', InputOption::VALUE_OPTIONAL, 'Rabbitmq connection name', 'default') |
53 | 53 | ->addOption('timeout', 't', InputOption::VALUE_OPTIONAL, 'Timeout', 500) |
54 | 54 | ->addOption('qos-prefetch-size', null, InputOption::VALUE_OPTIONAL, 'Qos prefetch size', 0) |
55 | - ->addOption('qos-prefetch-count', null,InputOption::VALUE_OPTIONAL, 'Qos prefetch count', 10) |
|
56 | - ->addOption('qos-global', null,InputOption::VALUE_OPTIONAL, 'Qos global', true) |
|
55 | + ->addOption('qos-prefetch-count', null, InputOption::VALUE_OPTIONAL, 'Qos prefetch count', 10) |
|
56 | + ->addOption('qos-global', null, InputOption::VALUE_OPTIONAL, 'Qos global', true) |
|
57 | 57 | ; |
58 | 58 | } |
59 | 59 | |
@@ -101,7 +101,7 @@ discard block |
||
101 | 101 | throw new \BadFunctionCallException("Function 'pcntl_signal' is referenced in the php.ini 'disable_functions' and can't be called."); |
102 | 102 | } |
103 | 103 | |
104 | - $stopConsumer = function () use ($consumers) { |
|
104 | + $stopConsumer = function() use ($consumers) { |
|
105 | 105 | foreach ($consumers as $consumer) { |
106 | 106 | $consumer->forceStopConsumer(); |
107 | 107 |