AC-14558::Migration form RabbitMQ to Apache ActiveMQ

Author: djadobe16

dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/RemoteServiceCommunicationTest.php

@@ -45,6 +45,7 @@ public function testRemoteServiceCommunication()
 
         $input = 'Input value';
         /** @var ServiceInterface $generatedRemoteService */
+        /** @phpstan-ignore-next-line */
         $generatedRemoteService = $this->objectManager->get(ServiceInterface::class);
         $response = $generatedRemoteService->execute($input);
         $this->assertEquals($input . ' processed by RPC handler', $response);

lib/internal/Magento/Framework/MessageQueue/Consumer.php

@@ -1,7 +1,7 @@
 <?php
 /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
+ * Copyright 2015 Adobe
+ * All Rights Reserved.
  */
 
 namespace Magento\Framework\MessageQueue;

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

@@ -1,7 +1,7 @@
 <?php
 /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
+ * Copyright 2017 Adobe
+ * All Rights Reserved.
  */
 declare(strict_types=1);
 

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

@@ -1,7 +1,7 @@
 <?php
 /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
+ * Copyright 2017 Adobe
+ * All Rights Reserved.
  */
 declare(strict_types=1);
 
@@ -199,7 +199,15 @@ public function testProcessWithNotFoundException()
         $envelope->expects($this->once())->method('getProperties')->willReturn($properties);
         $this->communicationConfig->expects($this->once())->method('getTopic')->with($properties['topic_name'])
             ->willReturn($topicConfig);
-        $this->configuration->expects($this->once())->method('getConsumerName')->willReturn($consumerName);
+        $this->configuration->expects($this->atLeastOnce())->method('getConsumerName')->willReturn($consumerName);
+        $consumerConfigItem = $this->getMockBuilder(
+            \Magento\Framework\MessageQueue\Consumer\Config\ConsumerConfigItemInterface::class
+        )
+            ->disableOriginalConstructor()
+            ->getMockForAbstractClass();
+        $consumerConfigItem->expects($this->once())->method('getConnection')->willReturn('connection_name');
+        $this->consumerConfig->expects($this->once())->method('getConsumer')->with($consumerName)
+            ->willReturn($consumerConfigItem);
         $this->messageController->expects($this->once())->method('lock')->with($envelope, $consumerName)
             ->willThrowException(
                 new NotFoundException(
@@ -227,6 +235,16 @@ public function testProcessWithGetMaxIdleTimeAndGetSleepConsumerConfigurations()
         $queue->expects($this->atMost(2))->method('dequeue')->willReturn(null);
         $this->configuration->expects($this->once())->method('getMaxIdleTime')->willReturn('2');
         $this->configuration->expects($this->once())->method('getSleep')->willReturn('2');
+        $consumerName = 'consumer.name';
+        $this->configuration->expects($this->once())->method('getConsumerName')->willReturn($consumerName);
+        $consumerConfigItem = $this->getMockBuilder(
+            \Magento\Framework\MessageQueue\Consumer\Config\ConsumerConfigItemInterface::class
+        )
+            ->disableOriginalConstructor()
+            ->getMockForAbstractClass();
+        $consumerConfigItem->expects($this->once())->method('getConnection')->willReturn('connection_name');
+        $this->consumerConfig->expects($this->once())->method('getConsumer')->with($consumerName)
+            ->willReturn($consumerConfigItem);
         $this->consumer->process($numberOfMessages);
     }
 }

lib/internal/Magento/Framework/MessageQueue/Test/Unit/_files/queue_publisher/valid.php

@@ -1,7 +1,7 @@
 <?php
 /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
+ * Copyright 2016 Adobe
+ * All Rights Reserved.
  */
 declare(strict_types=1);
 

lib/internal/Magento/Framework/Stomp/Diagnostics.php

@@ -61,6 +61,7 @@ public function __construct(
      *
      * @param string|null $connectionName
      * @return array
+     * @SuppressWarnings(PHPMD.UnusedLocalVariable)
      */
     public function runDiagnostics(?string $connectionName = null): array
     {
@@ -88,9 +89,6 @@ public function runDiagnostics(?string $connectionName = null): array
 
             // Test additional STOMP connections
             if (isset($queueConfig['connections'])) {
-                /**
-                 * @SuppressWarnings(PHPMD.UnusedLocalVariable)
-                 */
                 foreach ($queueConfig['connections'] as $name => $config) {
                     $results['connections'][$name] = $this->testStompConnection($name);
                 }
@@ -320,12 +318,10 @@ private function testNetworkConnectivity(string $host, int $port): array
      *
      * @param string $connectionName
      * @return array
+     * @SuppressWarnings(PHPMD.UnusedLocalVariable)
      */
     private function testStompClientCreation(string $connectionName): array
     {
-        /**
-         * @SuppressWarnings(PHPMD.UnusedLocalVariable)
-         */
         try {
             $config = new Config($this->deploymentConfig, $connectionName);
             $client = $this->stompClientFactory->create();
@@ -347,13 +343,11 @@ private function testStompClientCreation(string $connectionName): array
      *
      * @param string $connectionName
      * @return array
+     * @SuppressWarnings(PHPMD.UnusedLocalVariable)
      */
     private function testStompBasicOperations(string $connectionName): array
     {
         try {
-            /**
-             * @SuppressWarnings(PHPMD.UnusedLocalVariable)
-             */
             $config = new Config($this->deploymentConfig, $connectionName);
             $client = $this->stompClientFactory->create();