|
@@ -52,8 +52,8 @@ discard block |
|
|
block discarded – undo |
|
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 |
|
|
block discarded – undo |
|
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
|
|