Skip to content

Commit 2249665

Browse files
committed
AC-14558::Migration form RabbitMQ to Apache ActiveMQ
1 parent 3cb9b9b commit 2249665

File tree

2 files changed

+13
-8
lines changed

2 files changed

+13
-8
lines changed

dev/tests/integration/testsuite/Magento/Framework/Stomp/WaitAndNotWaitMessagesTest.php renamed to dev/tests/integration/testsuite/Magento/Framework/Stomp/UseCase/WaitAndNotWaitMessagesTest.php

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,9 @@
33
* Copyright 2025 Adobe
44
* All Rights Reserved.
55
*/
6-
namespace Magento\Framework\Stomp;
6+
declare(strict_types=1);
7+
8+
namespace Magento\Framework\Stomp\UseCase;
79

810
use Magento\Framework\App\DeploymentConfig\FileReader;
911
use Magento\Framework\App\DeploymentConfig\Writer;
@@ -91,7 +93,7 @@ private function getMsgObject(): AsyncTestData
9193
/**
9294
* Check if consumers wait for messages from the queue
9395
*/
94-
public function testWaitForMessages()
96+
public function testWaitForMessages(): void
9597
{
9698
if ($this->connectionType === 'amqp') {
9799
$this->markTestSkipped('STOMP test skipped because AMQP connection is available.
Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -3,13 +3,16 @@
33
* Copyright 2025 Adobe
44
* All Rights Reserved.
55
*/
6-
namespace Magento\Framework\MessageQueue\UseCase;
6+
declare(strict_types=1);
7+
8+
namespace Magento\Framework\Stomp\UseCase;
79

810
use Magento\Framework\MessageQueue\DefaultValueProvider;
11+
use Magento\Framework\MessageQueue\UseCase\QueueTestCaseAbstract;
912
use Magento\TestFramework\Helper\Bootstrap;
1013
use Magento\TestModuleAsyncStomp\Model\AsyncTestData;
1114

12-
class WildcardTopicStompTest extends QueueTestCaseAbstract
15+
class WildcardTopicTest extends QueueTestCaseAbstract
1316
{
1417
/**
1518
* @var string[]
@@ -46,7 +49,7 @@ protected function setUp(): void
4649
*
4750
* @dataProvider wildCardTopicsDataProvider
4851
*/
49-
public function testWildCardMatchingTopic($topic, $matchingQueues, $nonMatchingQueues)
52+
public function testWildCardMatchingTopic(string $topic, array $matchingQueues, array $nonMatchingQueues): void
5053
{
5154
if ($this->connectionType === 'amqp') {
5255
$this->markTestSkipped('STOMP test skipped because AMQP connection is available.
@@ -67,7 +70,7 @@ public function testWildCardMatchingTopic($topic, $matchingQueues, $nonMatchingQ
6770
}
6871
}
6972

70-
public static function wildCardTopicsDataProvider()
73+
public static function wildCardTopicsDataProvider(): array
7174
{
7275
return [
7376
'stomp.segment1.segment2.segment3.wildcard' => [
@@ -83,7 +86,7 @@ public static function wildCardTopicsDataProvider()
8386
];
8487
}
8588

86-
public function testWildCardNonMatchingTopic()
89+
public function testWildCardNonMatchingTopic(): void
8790
{
8891
if ($this->connectionType === 'amqp') {
8992
$this->markTestSkipped('STOMP test skipped because AMQP connection is available.
@@ -99,7 +102,7 @@ public function testWildCardNonMatchingTopic()
99102
/**
100103
* @return AsyncTestData
101104
*/
102-
private function generateTestObject()
105+
private function generateTestObject(): AsyncTestData
103106
{
104107
$testObject = $this->objectManager->create(AsyncTestData::class); // @phpstan-ignore-line
105108
$testObject->setValue('||Message Contents||');

0 commit comments

Comments
 (0)