B2B-2155: Use Redis as message queue

- enable the test to run with different queue connection.

Author: joanhe

dev/tests/integration/testsuite/Magento/Framework/MessageQueue/Consumer/ConfigTest.php

@@ -6,6 +6,7 @@
 namespace Magento\Framework\MessageQueue\Consumer;
 
 use Magento\Framework\MessageQueue\Consumer\Config\ConsumerConfigItem\Handler\Iterator as HandlerIterator;
+use Magento\Framework\MessageQueue\DefaultValueProvider;
 
 /**
  * Test of queue consumer configuration reading and parsing.
@@ -19,9 +20,15 @@ class ConfigTest extends \PHPUnit\Framework\TestCase
      */
     private $objectManager;
 
+    /**
+     * @var DefaultValueProvider
+     */
+    private $defaultValueProvider;
+
     protected function setUp(): void
     {
         $this->objectManager = \Magento\TestFramework\Helper\Bootstrap::getObjectManager();
+        $this->defaultValueProvider = $this->objectManager->get(DefaultValueProvider::class);
     }
 
     public function testGetConsumers()
@@ -59,7 +66,7 @@ public function testGetConsumerWithDefaultValues()
 
         $this->assertEquals('consumer5', $consumer->getName());
         $this->assertEquals('queue5', $consumer->getQueue());
-        $this->assertEquals('db', $consumer->getConnection());
+        $this->assertEquals($this->defaultValueProvider->getConnection(), $consumer->getConnection());
         $this->assertEquals(\Magento\Framework\MessageQueue\ConsumerInterface::class, $consumer->getConsumerInstance());
         $this->assertNull($consumer->getMaxMessages());
         $handlers = $consumer->getHandlers();

dev/tests/integration/testsuite/Magento/Framework/MessageQueue/Publisher/ConfigTest.php

@@ -5,6 +5,8 @@
  */
 namespace Magento\Framework\MessageQueue\Publisher;
 
+use Magento\Framework\MessageQueue\DefaultValueProvider;
+
 /**
  * Test of queue publisher configuration reading and parsing.
  *
@@ -17,9 +19,15 @@ class ConfigTest extends \PHPUnit\Framework\TestCase
      */
     private $objectManager;
 
+    /**
+     * @var DefaultValueProvider
+     */
+    private $defaultValueProvider;
+
     protected function setUp(): void
     {
         $this->objectManager = \Magento\TestFramework\Helper\Bootstrap::getObjectManager();
+        $this->defaultValueProvider = $this->objectManager->get(DefaultValueProvider::class);
     }
 
     public function testGetPublishersWithOneEnabledConnection()
@@ -70,7 +78,7 @@ public function testGetPublishersWithoutEnabledConnection()
 
         /** @var \Magento\Framework\MessageQueue\Publisher\Config\PublisherConnectionInterface $connection */
         $connection = $publisher->getConnection();
-        $this->assertEquals('db', $connection->getName(), 'Incorrect default connection name');
+        $this->assertEquals($this->defaultValueProvider->getConnection(), $connection->getName(), 'Incorrect default connection name');
         $this->assertEquals('magento', $connection->getExchange(), 'Incorrect default exchange name');
         $this->assertFalse($connection->isDisabled(), 'Incorrect connection status');
     }