B2B-2155: Use Redis as message queue

- fix unit tests

Author: joanhe

lib/internal/Magento/Framework/MessageQueue/Test/Unit/Config/Reader/Xml/Converter/TopicConverterTest.php

@@ -10,6 +10,7 @@
 use Magento\Framework\Communication\ConfigInterface;
 use Magento\Framework\MessageQueue\Config\Reader\Xml\Converter\TopicConfig;
 use Magento\Framework\MessageQueue\Config\Validator;
+use Magento\Framework\MessageQueue\DefaultValueProvider;
 use Magento\Framework\Reflection\MethodsMap;
 use PHPUnit\Framework\MockObject\MockObject;
 use PHPUnit\Framework\TestCase;
@@ -38,6 +39,11 @@ class TopicConverterTest extends TestCase
      */
     protected $communicationConfigMock;
 
+    /**
+     * @var DefaultValueProvider|MockObject
+     */
+    private $defaultValueProviderMock;
+
     /**
      * Initialize parameters
      */
@@ -59,11 +65,12 @@ protected function setUp(): void
         $this->communicationConfigMock->expects($this->once())->method('getTopics')->willReturn($topicsDefinitions);
 
         $this->communicationConfigMock->expects($this->any())->method('getTopic')->willReturnMap($topicsMap);
-
+        $this->defaultValueProviderMock = $this->createMock(DefaultValueProvider::class);
         $this->converter = new TopicConfig(
             $this->methodMapMock,
             $this->validatorMock,
-            $this->communicationConfigMock
+            $this->communicationConfigMock,
+            $this->defaultValueProviderMock
         );
     }
 

lib/internal/Magento/Framework/MessageQueue/Test/Unit/DefaultValueProviderTest.php

@@ -39,6 +39,11 @@ protected function setUp(): void
      */
     public function testGetConnection(): void
     {
+        $this->config->method('get')->willReturnMap(
+            [
+                ['queue', null, ['key' => 'test_connection']],
+            ]
+        );
         $this->assertEquals('db', $this->model->getConnection());
     }
 
@@ -66,7 +71,8 @@ public function testGetAMQPConnection(): void
         $this->config->method('get')->willReturnMap(
             [
                 ['queue/default_connection', null, null],
-                ['queue/amqp', null, ['host' => '127.0.0.1', 'port' => '5672']]
+                ['queue/amqp', null, ['host' => '127.0.0.1', 'port' => '5672']],
+                ['queue', null, ['amqp' => ['host' => '127.0.0.1', 'port' => '5672']]]
             ]
         );