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

adifucan · adifucan · commit 20ad77f6c04d · 2022-01-25T21:11:11.000-06:00
- Fix failed integration tests;
diff --git a/lib/internal/Magento/Framework/MessageQueue/Publisher/Config/RemoteService/Reader.php b/lib/internal/Magento/Framework/MessageQueue/Publisher/Config/RemoteService/Reader.php
@@ -65,10 +65,9 @@ public function __construct(
     public function read($scope = null)
     {
         $result = [];
-        $connectionName = $this->defaultValueProvider->getConnection();
         $connections = [
-            $connectionName => [
-                'name' => $connectionName,
+            'amqp' => [
+                'name' => 'amqp',
                 'exchange' => $this->defaultValueProvider->getExchange(),
                 'disabled' => false,
             ]

Original file line number	Diff line number	Diff line change
`@@ -65,10 +65,9 @@ public function __construct(`
`65`	`65`	`public function read($scope = null)`
`66`	`66`	`{`
`67`	`67`	`$result = [];`
`68`		`- $connectionName = $this->defaultValueProvider->getConnection();`
`69`	`68`	`$connections = [`
`70`		`- $connectionName => [`
`71`		`- 'name' => $connectionName,`
	`69`	`+ 'amqp' => [`
	`70`	`+ 'name' => 'amqp',`
`72`	`71`	`'exchange' => $this->defaultValueProvider->getExchange(),`
`73`	`72`	`'disabled' => false,`
`74`	`73`	`]`