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

- Set amqp connection for WebapiAsync;

Author: adifucan

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

@@ -146,22 +146,20 @@ public function run()
 
                     $this->shellBackground->execute($command, $arguments);
                 }
-            } else {
-                if (!$this->lockManager->isLocked(md5($consumer->getName()))) { //phpcs:ignore
-                    $arguments = [
-                        $consumer->getName(),
-                        '--single-thread'
-                    ];
-
-                    if ($maxMessages) {
-                        $arguments[] = '--max-messages=' . min($consumer->getMaxMessages() ?? $maxMessages, $maxMessages);
-                    }
+            } else if (!$this->lockManager->isLocked(md5($consumer->getName()))) { //phpcs:ignore
+                $arguments = [
+                    $consumer->getName(),
+                    '--single-thread'
+                ];
+
+                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="db"
+    <consumer name="async.operations.all" queue="async.operations.all" connection="amqp"
               consumerInstance="Magento\AsynchronousOperations\Model\MassConsumer"/>
 </config>