B2B-2155: Use Redis as message queue

- enable the test to run with different queue connection.

Author: joanhe

dev/tests/integration/testsuite/Magento/CatalogImportExport/Model/Import/ImportWithNotExistImagesTest.php

@@ -7,21 +7,23 @@
 
 namespace Magento\CatalogImportExport\Model\Import;
 
+use Magento\Catalog\Api\Data\ProductAttributeInterface;
+use Magento\Catalog\Api\Data\ProductInterface;
 use Magento\Catalog\Api\ProductRepositoryInterface;
 use Magento\Catalog\Model\Product;
 use Magento\CatalogImportExport\Model\Import\Product\RowValidatorInterface;
 use Magento\CatalogImportExport\Model\Import\ProductImport;
 use Magento\Framework\App\Filesystem\DirectoryList;
-use Magento\Framework\File\Csv;
 use Magento\Framework\Filesystem;
 use Magento\Framework\Filesystem\Directory\Write;
-use Magento\Framework\MessageQueue\MessageEncoder;
+use Magento\Framework\MessageQueue\ConsumerFactory;
+use Magento\Framework\MessageQueue\PublisherInterface;
 use Magento\Framework\ObjectManagerInterface;
-use Magento\ImportExport\Model\Export\Consumer;
+use Magento\ImportExport\Model\Export\Entity\ExportInfo;
+use Magento\ImportExport\Model\Export\Entity\ExportInfoFactory;
 use Magento\ImportExport\Model\Import as ImportModel;
 use Magento\ImportExport\Model\Import\Source\Csv as CsvSource;
 use Magento\ImportExport\Model\Import\Source\CsvFactory;
-use Magento\MysqlMq\Model\Driver\Queue;
 use Magento\TestFramework\Helper\Bootstrap;
 use Magento\TestFramework\MysqlMq\DeleteTopicRelatedMessages;
 use PHPUnit\Framework\TestCase;
@@ -42,17 +44,8 @@ class ImportWithNotExistImagesTest extends TestCase
     /** @var ObjectManagerInterface */
     private $objectManager;
 
-    /** @var MessageEncoder */
-    private $messageEncoder;
-
-    /** @var Consumer */
-    private $consumer;
-
-    /** @var Queue */
-    private $queue;
-
-    /** @var Csv */
-    private $csvReader;
+    /** @var ConsumerFactory */
+    private $consumerFactory;
 
     /** @var Write */
     private $directory;
@@ -93,10 +86,7 @@ protected function setUp(): void
         parent::setUp();
 
         $this->objectManager = Bootstrap::getObjectManager();
-        $this->queue = $this->objectManager->create(Queue::class, ['queueName' => 'export']);
-        $this->messageEncoder = $this->objectManager->get(MessageEncoder::class);
-        $this->consumer = $this->objectManager->get(Consumer::class);
-        $this->csvReader = $this->objectManager->get(Csv::class);
+        $this->consumerFactory = $this->objectManager->get(ConsumerFactory::class);
         $this->import = $this->objectManager->get(ProductFactory::class)->create();
         $this->csvFactory = $this->objectManager->get(CsvFactory::class);
         $this->fileSystem = $this->objectManager->get(Filesystem::class);
@@ -118,13 +108,27 @@ protected function tearDown(): void
     }
 
     /**
-     * @magentoDataFixture Magento/CatalogImportExport/_files/export_queue_product_with_images.php
+     * @magentoDataFixture Magento/Catalog/_files/product_with_image.php
      *
      * @return void
      */
     public function testImportWithUnexistingImages(): void
     {
+        $cache = $this->objectManager->get(\Magento\Framework\App\Cache::class);
+        $cache->clean();
+        /** @var ExportInfoFactory $exportInfoFactory */
+        $exportInfoFactory = $this->objectManager->get(ExportInfoFactory::class);
+        $messagePublisher = $this->objectManager->get(PublisherInterface::class);
+        /** @var ExportInfo $dataObject */
+        $dataObject = $exportInfoFactory->create(
+            'csv',
+            ProductAttributeInterface::ENTITY_TYPE_CODE,
+            [ProductInterface::SKU => 'simple'],
+            []
+        );
+        $messagePublisher->publish(self::TOPIC, $dataObject);
         $this->exportProducts();
+        $this->filePath = 'export/' . $dataObject->getFileName();
         $this->assertTrue($this->directory->isExist($this->filePath), 'Products were not imported to file');
         $fileContent = $this->getCsvData($this->directory->getAbsolutePath($this->filePath));
         $this->assertCount(2, $fileContent);
@@ -147,10 +151,8 @@ public function testImportWithUnexistingImages(): void
      */
     private function exportProducts(): void
     {
-        $envelope = $this->queue->dequeue();
-        $decodedMessage = $this->messageEncoder->decode(self::TOPIC, $envelope->getBody());
-        $this->consumer->process($decodedMessage);
-        $this->filePath = 'export/' . $decodedMessage->getFileName();
+        $consumer = $this->consumerFactory->get('exportProcessor');
+        $consumer->process(1);
     }
 
     /**