AC-14558::Migration form RabbitMQ to Apache ActiveMQ

djadobe16 · djadobe16 · commit 7361b1d5f9a5 · 2025-07-24T13:48:03.000+05:30
diff --git a/app/code/Magento/Amqp/Setup/ConfigOptionsList.php b/app/code/Magento/Amqp/Setup/ConfigOptionsList.php
@@ -205,9 +205,8 @@ public function validate(array $options, DeploymentConfig $deploymentConfig)
                 $errors[] = "Could not connect to the Amqp Server.";
             }
 
-            if(isset($options[self::INPUT_KEY_QUEUE_DEFAULT_CONNECTION])
-                && $options[self::INPUT_KEY_QUEUE_DEFAULT_CONNECTION] === 'stomp')
-            {
+            if (isset($options[self::INPUT_KEY_QUEUE_DEFAULT_CONNECTION])
+                && $options[self::INPUT_KEY_QUEUE_DEFAULT_CONNECTION] !== 'amqp') {
                 $errors = [];
             }
         }
diff --git a/app/code/Magento/AsynchronousOperations/Model/MassConsumer.php b/app/code/Magento/AsynchronousOperations/Model/MassConsumer.php
@@ -85,7 +85,9 @@ public function process($maxNumberOfMessages = null)
         if (!isset($maxNumberOfMessages)) {
             $queue->subscribe($this->getTransactionCallback($queue));
         } else {
-            $connectionName = $this->consumerConfig->getConsumer($this->configuration->getConsumerName())->getConnection();
+            $connectionName = $this->consumerConfig
+                              ->getConsumer($this->configuration->getConsumerName())
+                              ->getConnection();
             $this->invoker->invoke(
                 $queue,
                 $maxNumberOfMessages,
diff --git a/app/code/Magento/MessageQueue/Model/CheckIsAvailableMessagesInQueue.php b/app/code/Magento/MessageQueue/Model/CheckIsAvailableMessagesInQueue.php
@@ -1,7 +1,7 @@
 <?php
 /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
+ * Copyright 2015 Adobe
+ * All Rights Reserved.
  */
 declare(strict_types=1);
 
diff --git a/app/code/Magento/MysqlMq/Model/Driver/Queue.php b/app/code/Magento/MysqlMq/Model/Driver/Queue.php
@@ -161,6 +161,7 @@ public function push(EnvelopeInterface $envelope)
             $envelope->getBody(),
             [$this->queueName]
         );
+        return $envelope;
     }
 
     /**
@@ -182,9 +183,12 @@ public function subscribeQueue()
     }
 
     /**
+     * Clear queue
+     *
      * @return int
      */
     public function clearQueue(): int
     {
+        return 1;
     }
 }
diff --git a/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/Model/AsyncTestData.php b/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/Model/AsyncTestData.php
@@ -3,6 +3,8 @@
  * Copyright 2025 Adobe
  * All Rights Reserved.
  */
+declare(strict_types=1);
+
 namespace Magento\TestModuleAsyncStomp\Model;
 
 class AsyncTestData
diff --git a/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/Model/CustomHandler.php b/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/Model/CustomHandler.php
@@ -3,6 +3,8 @@
  * Copyright 2025 Adobe
  * All Rights Reserved.
  */
+declare(strict_types=1);
+
 namespace Magento\TestModuleAsyncStomp\Model;
 
 class CustomHandler
diff --git a/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/Model/RequestHandler.php b/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/Model/RequestHandler.php
@@ -3,6 +3,8 @@
  * Copyright 2025 Adobe
  * All Rights Reserved.
  */
+declare(strict_types=1);
+
 namespace Magento\TestModuleAsyncStomp\Model;
 
 class RequestHandler
diff --git a/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/Model/WildCardHandler.php b/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/Model/WildCardHandler.php
@@ -3,6 +3,8 @@
  * Copyright 2025 Adobe
  * All Rights Reserved.
  */
+declare(strict_types=1);
+
 namespace Magento\TestModuleAsyncStomp\Model;
 
 class WildCardHandler
diff --git a/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/communication.xml b/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/communication.xml
@@ -1,8 +1,8 @@
 <?xml version="1.0"?>
 <!--
 /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
+ * Copyright 2025 Adobe
+ * All Rights Reserved.
  */
 -->
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework:Communication/etc/communication.xsd">
diff --git a/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/module.xml b/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/module.xml
@@ -1,8 +1,8 @@
 <?xml version="1.0"?>
 <!--
 /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
+ * Copyright 2025 Adobe
+ * All Rights Reserved.
  */
 -->
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework:Module/etc/module.xsd">
diff --git a/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/queue_consumer.xml b/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/queue_consumer.xml
@@ -1,8 +1,7 @@
-<!--<?xml version="1.0"?>-->
 <!--
 /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
+ * Copyright 2025 Adobe
+ * All Rights Reserved.
  */
 -->
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/consumer.xsd">
diff --git a/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/queue_publisher.xml b/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/queue_publisher.xml
@@ -1,8 +1,7 @@
-<!--<?xml version="1.0"?>-->
 <!--
 /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
+ * Copyright 2025 Adobe
+ * All Rights Reserved.
  */
 -->
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/publisher.xsd">
diff --git a/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/queue_topology.xml b/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/queue_topology.xml
@@ -1,8 +1,8 @@
 <?xml version="1.0"?>
 <!--
 /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
+ * Copyright 2025 Adobe
+ * All Rights Reserved.
  */
 -->
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
diff --git a/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/registration.php b/dev/tests/integration/_files/Magento/TestModuleAsyncStomp/registration.php
@@ -3,6 +3,7 @@
  * Copyright 2025 Adobe
  * All Rights Reserved.
  */
+declare(strict_types=1);
 
 use Magento\Framework\Component\ComponentRegistrar;
 
diff --git a/dev/tests/integration/framework/Magento/TestFramework/Helper/Stomp.php b/dev/tests/integration/framework/Magento/TestFramework/Helper/Stomp.php
@@ -3,6 +3,7 @@
  * Copyright 2025 Adobe
  * All Rights Reserved.
  */
+declare(strict_types=1);
 
 namespace Magento\TestFramework\Helper;
 
diff --git a/dev/tests/integration/framework/Magento/TestFramework/MessageQueue/ClearQueueProcessor.php b/dev/tests/integration/framework/Magento/TestFramework/MessageQueue/ClearQueueProcessor.php
@@ -1,7 +1,7 @@
 <?php
 /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
+ * Copyright 2022 Adobe
+ * All Rights Reserved.
  */
 declare(strict_types=1);
 
@@ -64,7 +64,7 @@ public function execute(string $consumerName): void
         $queue = $this->queueRepository->get($consumerConfig->getConnection(), $consumerConfig->getQueue());
 
         if ($consumerConfig->getConnection() === 'stomp') {
-            $clearedCount = $queue->clearQueue();
+            $queue->clearQueue();
         } else {
             // AMQP and other protocols use the standard approach
             while ($message = $queue->dequeue()) {
diff --git a/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/TopologyTest.php b/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/TopologyTest.php
@@ -64,7 +64,8 @@ protected function setUp(): void
     public function testTopologyInstallation(array $expectedConfig, array $bindingConfig): void
     {
         if ($this->connectionType === 'stomp') {
-            $this->markTestSkipped('AMQP test skipped because STOMP connection is available. This test is AMQP-specific.');
+            $this->markTestSkipped('AMQP test skipped because STOMP connection is available.
+            This test is AMQP-specific.');
         }
 
         $name = $expectedConfig['name'];
diff --git a/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/AsyncMultipleHandlersTest.php b/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/AsyncMultipleHandlersTest.php
@@ -73,7 +73,8 @@ protected function setUp(): void
     public function testAsynchronousRpcCommunication()
     {
         if ($this->connectionType === 'stomp') {
-            $this->markTestSkipped('AMQP test skipped because STOMP connection is available. This test is AMQP-specific.');
+            $this->markTestSkipped('AMQP test skipped because STOMP connection is available.
+            This test is AMQP-specific.');
         }
 
         foreach ($this->topicValueMap as $topic => $data) {
diff --git a/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/AsyncMultipleTopicsWithEachQueueTest.php b/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/AsyncMultipleTopicsWithEachQueueTest.php
@@ -59,7 +59,8 @@ protected function setUp(): void
     public function testAsyncMultipleTopicsPerQueue()
     {
         if ($this->connectionType === 'stomp') {
-            $this->markTestSkipped('AMQP test skipped because STOMP connection is available. This test is AMQP-specific.');
+            $this->markTestSkipped('AMQP test skipped because STOMP connection is available.
+            This test is AMQP-specific.');
         }
 
         $this->msgObject = $this->objectManager->create(AsyncTestData::class); // @phpstan-ignore-line
diff --git a/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/DeprecatedFormat/AsyncMultiTopicsSeparateQueuesTest.php b/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/DeprecatedFormat/AsyncMultiTopicsSeparateQueuesTest.php
@@ -63,7 +63,8 @@ protected function setUp(): void
     public function testAsyncMultipleTopicsPerQueue()
     {
         if ($this->connectionType === 'stomp') {
-            $this->markTestSkipped('AMQP test skipped because STOMP connection is available. This test is AMQP-specific.');
+            $this->markTestSkipped('AMQP test skipped because STOMP connection is available.
+            This test is AMQP-specific.');
         }
 
         $this->msgObject = $this->objectManager->create(AsyncTestData::class); // @phpstan-ignore-line
diff --git a/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/DeprecatedFormat/RpcCommunicationTest.php b/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/DeprecatedFormat/RpcCommunicationTest.php
@@ -12,7 +12,7 @@
 class RpcCommunicationTest extends QueueTestCaseAbstract
 {
     /**
-     * {@inheritdoc}
+     * @var string[]
      */
     protected $consumers = ['synchronousRpcTestConsumer.deprecated'];
 
@@ -44,7 +44,8 @@ protected function setUp(): void
     public function testSynchronousRpcCommunication()
     {
         if ($this->connectionType === 'stomp') {
-            $this->markTestSkipped('AMQP test skipped because STOMP connection is available. This test is AMQP-specific.');
+            $this->markTestSkipped('AMQP test skipped because STOMP connection is available.
+            This test is AMQP-specific.');
         }
 
         $input = 'Input value';
diff --git a/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/MixSyncAndAsyncSingleQueueTest.php b/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/MixSyncAndAsyncSingleQueueTest.php
@@ -17,7 +17,7 @@ class MixSyncAndAsyncSingleQueueTest extends QueueTestCaseAbstract
     protected $msgObject;
 
     /**
-     * {@inheritdoc}
+     * @var string[]
      */
     protected $consumers = ['mixed.sync.and.async.queue.consumer'];
 
@@ -54,7 +54,8 @@ protected function setUp(): void
     public function testMixSyncAndAsyncSingleQueue()
     {
         if ($this->connectionType === 'stomp') {
-            $this->markTestSkipped('AMQP test skipped because STOMP connection is available. This test is AMQP-specific.');
+            $this->markTestSkipped('AMQP test skipped because STOMP connection is available.
+            This test is AMQP-specific.');
         }
 
         $this->msgObject = $this->objectManager->create(AsyncTestData::class); // @phpstan-ignore-line
diff --git a/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/MultipleTopicsPerQueueTest.php b/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/MultipleTopicsPerQueueTest.php
@@ -11,7 +11,7 @@
 class MultipleTopicsPerQueueTest extends QueueTestCaseAbstract
 {
     /**
-     * {@inheritdoc}
+     * @var string[]
      */
     protected $consumers = [
         'queue.for.multiple.topics.test.a',
@@ -47,7 +47,8 @@ protected function setUp(): void
     public function testSynchronousRpcCommunication()
     {
         if ($this->connectionType === 'stomp') {
-            $this->markTestSkipped('AMQP test skipped because STOMP connection is available. This test is AMQP-specific.');
+            $this->markTestSkipped('AMQP test skipped because STOMP connection is available.
+            This test is AMQP-specific.');
         }
 
         foreach (['multi.topic.queue.topic.a', 'multi.topic.queue.topic.b'] as $topic) {
diff --git a/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/RemoteServiceCommunicationTest.php b/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/RemoteServiceCommunicationTest.php
@@ -12,7 +12,7 @@
 class RemoteServiceCommunicationTest extends QueueTestCaseAbstract
 {
     /**
-     * {@inheritdoc}
+     * @var string[]
      */
     protected $consumers = ['RemoteServiceTestConsumer'];
 
@@ -39,7 +39,8 @@ protected function setUp(): void
     public function testRemoteServiceCommunication()
     {
         if ($this->connectionType === 'stomp') {
-            $this->markTestSkipped('AMQP test skipped because STOMP connection is available. This test is AMQP-specific.');
+            $this->markTestSkipped('AMQP test skipped because STOMP connection is available.
+            This test is AMQP-specific.');
         }
 
         $input = 'Input value';
diff --git a/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/RpcCommunicationTest.php b/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/RpcCommunicationTest.php
@@ -11,7 +11,7 @@
 class RpcCommunicationTest extends QueueTestCaseAbstract
 {
     /**
-     * {@inheritdoc}
+     * @var string[]
      */
     protected $consumers = ['synchronousRpcTestConsumer'];
 
@@ -43,7 +43,8 @@ protected function setUp(): void
     public function testSynchronousRpcCommunication()
     {
         if ($this->connectionType === 'stomp') {
-            $this->markTestSkipped('AMQP test skipped because STOMP connection is available. This test is AMQP-specific.');
+            $this->markTestSkipped('AMQP test skipped because STOMP connection is available.
+            This test is AMQP-specific.');
         }
 
         $input = 'Input value';
diff --git a/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/WaitAndNotWaitMessagesTest.php b/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/WaitAndNotWaitMessagesTest.php
@@ -36,7 +36,7 @@ class WaitAndNotWaitMessagesTest extends QueueTestCaseAbstract
     protected $msgObject;
 
     /**
-     * {@inheritdoc}
+     * @var string[]
      */
     protected $consumers = ['mixed.sync.and.async.queue.consumer'];
 
@@ -81,7 +81,8 @@ protected function setUp(): void
     public function testWaitForMessages()
     {
         if ($this->connectionType === 'stomp') {
-            $this->markTestSkipped('AMQP test skipped because STOMP connection is available. This test is AMQP-specific.');
+            $this->markTestSkipped('AMQP test skipped because STOMP connection is available.
+            This test is AMQP-specific.');
         }
 
         $this->publisherConsumerController->stopConsumers();
@@ -115,8 +116,9 @@ public function testWaitForMessages()
      */
     public function testNotWaitForMessages(): void
     {
-        if ($this->connectionType === 'stomp'){
-            $this->markTestSkipped('AMQP test skipped because STOMP connection is available. This test is AMQP-specific.');
+        if ($this->connectionType === 'stomp') {
+            $this->markTestSkipped('AMQP test skipped because STOMP connection is available.
+            This test is AMQP-specific.');
         }
 
         $this->publisherConsumerController->stopConsumers();
diff --git a/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/WildcardTopicTest.php b/dev/tests/integration/testsuite/Magento/Framework/MessageQueue/UseCase/WildcardTopicTest.php
@@ -51,7 +51,8 @@ protected function setUp(): void
     public function testWildCardMatchingTopic($topic, $matchingQueues, $nonMatchingQueues)
     {
         if ($this->connectionType === 'stomp') {
-            $this->markTestSkipped('AMQP test skipped because STOMP connection is available. This test is AMQP-specific.');
+            $this->markTestSkipped('AMQP test skipped because STOMP connection is available.
+            This test is AMQP-specific.');
         }
 
         $testObject = $this->generateTestObject();
@@ -86,8 +87,9 @@ public static function wildCardTopicsDataProvider()
 
     public function testWildCardNonMatchingTopic()
     {
-        if ($this->connectionType === 'stomp'){
-            $this->markTestSkipped('AMQP test skipped because STOMP connection is available. This test is AMQP-specific.');
+        if ($this->connectionType === 'stomp') {
+            $this->markTestSkipped('AMQP test skipped because STOMP connection is available.
+            This test is AMQP-specific.');
         }
 
         $testObject = $this->generateTestObject();
diff --git a/dev/tests/integration/testsuite/Magento/Framework/Stomp/TopologyTest.php b/dev/tests/integration/testsuite/Magento/Framework/Stomp/TopologyTest.php
@@ -36,7 +36,6 @@ class TopologyTest extends TestCase
      */
     private $objectManager;
 
-
     /**
      * @var string
      */
@@ -53,7 +52,7 @@ protected function setUp(): void
         $defaultValueProvider = $this->objectManager->get(DefaultValueProvider::class);
         $this->connectionType = $defaultValueProvider->getConnection();
 
-        if($this->connectionType === 'stomp') {
+        if ($this->connectionType === 'stomp') {
             $this->helper = $this->objectManager->create(Stomp::class);
 
             if (!$this->helper->isAvailable()) {
@@ -69,8 +68,9 @@ protected function setUp(): void
      */
     public function testTopologyInstallation(array $expectedConfig): void
     {
-        if($this->connectionType === 'amqp') {
-            $this->markTestSkipped('STOMP test skipped because AMQP connection is available. This test is STOMP-specific.');
+        if ($this->connectionType === 'amqp') {
+            $this->markTestSkipped('STOMP test skipped because AMQP connection is available.
+            This test is STOMP-specific.');
         }
 
         $name = $expectedConfig['name'];
diff --git a/dev/tests/integration/testsuite/Magento/ImportExport/Controller/Adminhtml/Export/ExportTest.php b/dev/tests/integration/testsuite/Magento/ImportExport/Controller/Adminhtml/Export/ExportTest.php
diff --git a/lib/internal/Magento/Framework/Amqp/Queue.php b/lib/internal/Magento/Framework/Amqp/Queue.php
diff --git a/lib/internal/Magento/Framework/MessageQueue/BatchConsumer.php b/lib/internal/Magento/Framework/MessageQueue/BatchConsumer.php
diff --git a/lib/internal/Magento/Framework/MessageQueue/CallbackInvoker.php b/lib/internal/Magento/Framework/MessageQueue/CallbackInvoker.php
diff --git a/lib/internal/Magento/Framework/MessageQueue/CallbackInvokerInterface.php b/lib/internal/Magento/Framework/MessageQueue/CallbackInvokerInterface.php
diff --git a/lib/internal/Magento/Framework/MessageQueue/Consumer.php b/lib/internal/Magento/Framework/MessageQueue/Consumer.php
diff --git a/lib/internal/Magento/Framework/MessageQueue/Test/Unit/BatchConsumerTest.php b/lib/internal/Magento/Framework/MessageQueue/Test/Unit/BatchConsumerTest.php
diff --git a/lib/internal/Magento/Framework/Stomp/Bulk/Queue.php b/lib/internal/Magento/Framework/Stomp/Bulk/Queue.php
diff --git a/lib/internal/Magento/Framework/Stomp/Diagnostics.php b/lib/internal/Magento/Framework/Stomp/Diagnostics.php
diff --git a/lib/internal/Magento/Framework/Stomp/StompClient.php b/lib/internal/Magento/Framework/Stomp/StompClient.php
diff --git a/lib/internal/Magento/Framework/Stomp/Topology/QueueInstaller.php b/lib/internal/Magento/Framework/Stomp/Topology/QueueInstaller.php

Original file line number	Diff line number	Diff line change
`@@ -205,9 +205,8 @@ public function validate(array $options, DeploymentConfig $deploymentConfig)`
`205`	`205`	`$errors[] = "Could not connect to the Amqp Server.";`
`206`	`206`	`}`
`207`	`207`
`208`		`- if(isset($options[self::INPUT_KEY_QUEUE_DEFAULT_CONNECTION])`
`209`		`- && $options[self::INPUT_KEY_QUEUE_DEFAULT_CONNECTION] === 'stomp')`
`210`		`- {`
	`208`	`+ if (isset($options[self::INPUT_KEY_QUEUE_DEFAULT_CONNECTION])`
	`209`	`+ && $options[self::INPUT_KEY_QUEUE_DEFAULT_CONNECTION] !== 'amqp') {`
`211`	`210`	`$errors = [];`
`212`	`211`	`}`
`213`	`212`	`}`
Original file line number	Diff line number	Diff line change
`@@ -161,6 +161,7 @@ public function push(EnvelopeInterface $envelope)`
`161`	`161`	`$envelope->getBody(),`
`162`	`162`	`[$this->queueName]`
`163`	`163`	`);`
	`164`	`+ return $envelope;`
`164`	`165`	`}`
`165`	`166`
`166`	`167`	`/**`
`@@ -182,9 +183,12 @@ public function subscribeQueue()`
`182`	`183`	`}`
`183`	`184`
`184`	`185`	`/**`
	`186`	`+ * Clear queue`
	`187`	`+ *`
`185`	`188`	`* @return int`
`186`	`189`	`*/`
`187`	`190`	`public function clearQueue(): int`
`188`	`191`	`{`
	`192`	`+ return 1;`
`189`	`193`	`}`
`190`	`194`	`}`