|
@@ -45,8 +45,8 @@ discard block |
|
|
block discarded – undo |
|
45
|
45
|
->addOption('connection', 'c', InputOption::VALUE_OPTIONAL, 'Rabbitmq connection name', 'default') |
|
46
|
46
|
->addOption('timeout', 't', InputOption::VALUE_OPTIONAL, 'Timeout', 500) |
|
47
|
47
|
->addOption('qos-prefetch-size', null, InputOption::VALUE_OPTIONAL, 'Qos prefetch size', 0) |
|
48
|
|
- ->addOption('qos-prefetch-count', null,InputOption::VALUE_OPTIONAL, 'Qos prefetch count', 10) |
|
49
|
|
- ->addOption('qos-global', null,InputOption::VALUE_OPTIONAL, 'Qos global', true) |
|
|
48
|
+ ->addOption('qos-prefetch-count', null, InputOption::VALUE_OPTIONAL, 'Qos prefetch count', 10) |
|
|
49
|
+ ->addOption('qos-global', null, InputOption::VALUE_OPTIONAL, 'Qos global', true) |
|
50
|
50
|
// TODO ?! ->addOption('messages', 'm', InputOption::VALUE_OPTIONAL, 'Messages to consume', 0) |
|
51
|
51
|
->addOption('memory-limit', 'l', InputOption::VALUE_OPTIONAL, 'Allowed memory for this process (MB)', null) |
|
52
|
52
|
->addOption('debug', 'd', InputOption::VALUE_NONE, 'Enable Debugging') |
|
@@ -98,7 +98,7 @@ discard block |
|
|
block discarded – undo |
|
98
|
98
|
throw new \BadFunctionCallException("Function 'pcntl_signal' is referenced in the php.ini 'disable_functions' and can't be called."); |
|
99
|
99
|
} |
|
100
|
100
|
|
|
101
|
|
- $stopConsumer = function () use ($consumers) { |
|
|
101
|
+ $stopConsumer = function() use ($consumers) { |
|
102
|
102
|
foreach ($consumers as $consumer) { |
|
103
|
103
|
$consumer->forceStopConsumer(); |
|
104
|
104
|
|
eMAGTechLabs /
RabbitMqBundle
