MCP-826: Use RabbitMQ for all consumers if AMQP is set in deployment config

- Print test server queue configuration;

Author: adifucan

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

@@ -9,27 +9,39 @@
 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
  */
 class Publisher implements \Magento\Framework\Config\ReaderInterface
 {
-
     /**
      * @var WebApiAsyncConfig
      */
     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);
     }
 
     /**
@@ -50,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,
                         ],

dev/tests/integration/testsuite/Magento/ImportExport/Model/Export/ConsumerTest.php

@@ -89,7 +89,7 @@ protected function tearDown(): void
      */
     public function testProcess(): void
     {
-        $this->objectManager->get('Psr\Log\LoggerInterface')->info('Amqp config ' . implode(" ", $this->deploymentConfig->get('queue/amqp')));
+        echo "Deployment config for queue is: " . json_encode($this->deploymentConfig->get('queue'));
         $envelope = $this->queue->dequeue();
         $decodedMessage = $this->messageEncoder->decode('import_export.export', $envelope->getBody());
         $this->consumer->process($decodedMessage);