MCP-771: [MCP-608] Multiple consumers prototype development

Author: vzabaznov

app/code/Magento/MessageQueue/Console/StartConsumerCommand.php

@@ -43,9 +43,6 @@ class StartConsumerCommand extends Command
     private $lockManager;
 
     /**
-     * StartConsumerCommand constructor.
-     * {@inheritdoc}
-     *
      * @param \Magento\Framework\App\State $appState
      * @param ConsumerFactory $consumerFactory
      * @param string $name
@@ -166,14 +163,15 @@ protected function configure()
 
 To do not run multiple copies of one consumer simultaneously:
 
-    <comment>%command.full_name% someConsumer --single-thread'</comment>
+    <comment>%command.full_name% someConsumer --single-thread</comment>
 
 To save PID enter path (This option is deprecated, use --single-thread instead):
 
     <comment>%command.full_name% someConsumer --pid-file-path='/var/someConsumer.pid'</comment>
+
 To define the number of processes per consumer:
 
-    <comment>%command.full_name% someConsumer --multi-process'</comment>
+    <comment>%command.full_name% someConsumer --multi-process</comment>
 HELP
         );
         parent::configure();

app/code/Magento/MessageQueue/Model/Cron/ConsumersRunner.php

@@ -60,8 +60,6 @@ class ConsumersRunner
     private $logger;
 
     /**
-     * Lock Manager
-     *
      * @var LockManagerInterface
      */
     private $lockManager;
@@ -139,7 +137,8 @@ public function run()
                     ];
 
                     if ($maxMessages) {
-                        $arguments[] = '--max-messages=' . min($consumer->getMaxMessages() ?? $maxMessages, $maxMessages);
+                        $arguments[] =
+                            '--max-messages=' . min($consumer->getMaxMessages() ?? $maxMessages, $maxMessages);
                     }
 
                     $command = $php . ' ' . BP . '/bin/magento queue:consumers:start %s %s'