Merge remote-tracking branch 'bulk/async-webapi-2' into async-webapi-2

Author: vrann

app/etc/di.xml

@@ -224,10 +224,10 @@
     <type name="Magento\Framework\Communication\Config\CompositeReader">
         <arguments>
             <argument name="readers" xsi:type="array">
-                <!--item name="asyncServiceReader" xsi:type="array">
+                <item name="asyncServiceReader" xsi:type="array">
                     <item name="reader" xsi:type="object">Magento\WebapiAsync\Code\Generator\Config\RemoteServiceReader\Communication</item>
                     <item name="sortOrder" xsi:type="string">0</item>
-                </item-->
+                </item>
                 <item name="xmlReader" xsi:type="array">
                     <item name="reader" xsi:type="object">Magento\Framework\Communication\Config\Reader\XmlReader</item>
                     <item name="sortOrder" xsi:type="string">10</item>
@@ -1610,7 +1610,7 @@
     <type name="Magento\Framework\MessageQueue\Publisher\Config\CompositeReader">
         <arguments>
             <argument name="readers" xsi:type="array">
-                <!--item name="asyncServiceReader" xsi:type="object" sortOrder="0">Magento\WebapiAsync\Code\Generator\Config\RemoteServiceReader\Publisher</item-->
+                <item name="asyncServiceReader" xsi:type="object" sortOrder="0">Magento\WebapiAsync\Code\Generator\Config\RemoteServiceReader\Publisher</item>
                 <item name="remoteServiceReader" xsi:type="object" sortOrder="10">Magento\Framework\MessageQueue\Publisher\Config\RemoteService\Reader</item>
                 <item name="xmlReader" xsi:type="object" sortOrder="20">Magento\Framework\MessageQueue\Publisher\Config\Xml\Reader</item>
                 <item name="envReader" xsi:type="object" sortOrder="30">Magento\Framework\MessageQueue\Publisher\Config\Env\Reader</item>

dev/tests/integration/framework/Magento/TestFramework/MessageQueue/PublisherConsumerController.php

@@ -81,7 +81,7 @@ public function initialize()
             );
         }
         $connections = $this->amqpHelper->getConnections();
-        foreach ($connections as $connectionName => $connectionData) {
+        foreach (array_keys($connections) as $connectionName) {
             $this->amqpHelper->deleteConnection($connectionName);
         }
         $this->amqpHelper->clearQueue("async.operations.all");