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

Author: aa-kashk

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

@@ -8,6 +8,7 @@
 namespace Magento\ImportExport\Model\Export;
 
 use Magento\Catalog\Api\Data\ProductInterface;
+use Magento\Framework\App\DeploymentConfig;
 use Magento\Framework\App\Filesystem\DirectoryList;
 use Magento\Framework\Filesystem;
 use Magento\Framework\Filesystem\Directory\WriteInterface;
@@ -45,6 +46,11 @@ class ConsumerTest extends TestCase
     /** @var string */
     private $filePath;
 
+    /**
+     * @var DeploymentConfig|null
+     */
+    private $deploymentConfig;
+
     /**
      * @inheritdoc
      */
@@ -58,6 +64,7 @@ protected function setUp(): void
         $this->consumer = $this->objectManager->get(Consumer::class);
         $filesystem = $this->objectManager->get(Filesystem::class);
         $this->directory = $filesystem->getDirectoryWrite(DirectoryList::VAR_IMPORT_EXPORT);
+        $this->deploymentConfig =  $this->objectManager->get(DeploymentConfig::class);
     }
 
     /**
@@ -82,6 +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')));
         $envelope = $this->queue->dequeue();
         $decodedMessage = $this->messageEncoder->decode('import_export.export', $envelope->getBody());
         $this->consumer->process($decodedMessage);