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

- Fix Unknown connection name amqp error;

Author: adifucan

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

@@ -147,23 +147,21 @@ public function run()
                     $this->shellBackground->execute($command, $arguments);
                 }
             } else {
-                if ($this->lockManager->isLocked(md5($consumer->getName()))) { //phpcs:ignore
-                    return false;
-                }
-
-                $arguments = [
-                    $consumer->getName(),
-                    '--single-thread'
-                ];
+                if (!$this->lockManager->isLocked(md5($consumer->getName()))) { //phpcs:ignore
+                    $arguments = [
+                        $consumer->getName(),
+                        '--single-thread'
+                    ];
 
-                if ($maxMessages) {
-                    $arguments[] = '--max-messages=' . min($consumer->getMaxMessages() ?? $maxMessages, $maxMessages);
-                }
+                    if ($maxMessages) {
+                        $arguments[] = '--max-messages=' . min($consumer->getMaxMessages() ?? $maxMessages, $maxMessages);
+                    }
 
-                $command = $php . ' ' . BP . '/bin/magento queue:consumers:start %s %s'
-                    . ($maxMessages ? ' %s' : '');
+                    $command = $php . ' ' . BP . '/bin/magento queue:consumers:start %s %s'
+                        . ($maxMessages ? ' %s' : '');
 
-                $this->shellBackground->execute($command, $arguments);
+                    $this->shellBackground->execute($command, $arguments);
+                }
             }
         }
     }

app/code/Magento/WebapiAsync/etc/queue_consumer.xml

@@ -7,6 +7,6 @@
 -->
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/consumer.xsd">
-    <consumer name="async.operations.all" queue="async.operations.all" connection="amqp"
+    <consumer name="async.operations.all" queue="async.operations.all" connection="db"
               consumerInstance="Magento\AsynchronousOperations\Model\MassConsumer"/>
-</config>
+</config>