B2B-2171: Enable WebapiAsync work with redis connection

Author: joanhe

app/code/Magento/WebapiAsync/Code/Generator/Config/RemoteServiceReader/Publisher.php

@@ -9,6 +9,8 @@
 namespace Magento\WebapiAsync\Code\Generator\Config\RemoteServiceReader;
 
 use Magento\AsynchronousOperations\Model\ConfigInterface as WebApiAsyncConfig;
+use Magento\Framework\App\ObjectManager;
+use Magento\Framework\MessageQueue\DefaultValueProvider;
 
 /**
  * Remote service reader with auto generated configuration for queue_publisher.xml
@@ -20,15 +22,26 @@ class Publisher implements \Magento\Framework\Config\ReaderInterface
      */
     private $webapiAsyncConfig;
 
+    /**
+     * Default value provider.
+     *
+     * @var DefaultValueProvider
+     */
+    private $defaultValueProvider;
+
     /**
      * Initialize dependencies.
      *
      * @param WebApiAsyncConfig $webapiAsyncConfig
+     * @param DefaultValueProvider|null $defaultValueProvider
      */
     public function __construct(
-        WebApiAsyncConfig $webapiAsyncConfig
+        WebApiAsyncConfig $webapiAsyncConfig,
+        DefaultValueProvider $defaultValueProvider = null
     ) {
         $this->webapiAsyncConfig = $webapiAsyncConfig;
+        $this->defaultValueProvider = $defaultValueProvider
+            ?? ObjectManager::getInstance()->get(DefaultValueProvider::class);
     }
 
     /**
@@ -49,8 +62,8 @@ public function read($scope = null)
                     'topic'       => $topicName,
                     'disabled'    => false,
                     'connections' => [
-                        'amqp' => [
-                            'name'     => 'amqp',
+                        $this->defaultValueProvider->getConnection() => [
+                            'name'     => $this->defaultValueProvider->getConnection(),
                             'exchange' => 'magento',
                             'disabled' => false,
                         ],

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"
               consumerInstance="Magento\AsynchronousOperations\Model\MassConsumer"/>
 </config>

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

@@ -6,7 +6,7 @@
  */
 -->
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
-    <exchange name="magento" connection="amqp">
+    <exchange name="magento">
         <binding id="async.operations.all" topic="async.#" destination="async.operations.all"/>
     </exchange>
 </config>