AC-14558::Migration form RabbitMQ to Apache ActiveMQ

Author: djadobe16

app/code/Magento/Stomp/etc/di.xml

@@ -25,7 +25,7 @@
                     <item name="stomp" xsi:type="object">Magento\Stomp\Model\Bulk\Publisher</item>
                 </item>
                 <item name="sync" xsi:type="array">
-                    <item name="stomp" xsi:type="object">Magento\Framework\MessageQueue\Bulk\Rpc\Publisher</item>
+                    <item name="stomp" xsi:type="object">Magento\Stomp\Model\Rpc\Publisher</item>
                 </item>
             </argument>
         </arguments>

dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/communication.xml

@@ -10,4 +10,11 @@
     <topic name="stomp.segment1.segment2.segment3.wildcard" request="Magento\TestModuleAsyncStomp\Model\AsyncTestData"/>
     <topic name="stomp.segment2.segment3.wildcard" request="Magento\TestModuleAsyncStomp\Model\AsyncTestData"/>
     <topic name="no.match.at.all" request="Magento\TestModuleAsyncStomp\Model\AsyncTestData"/>
+
+    <topic name="stomp.multi.topic.queue.topic.y" request="Magento\TestModuleAsyncStomp\Model\AsyncTestData">
+        <handler name="stomp.processAsyncReqC" type="Magento\TestModuleAsyncStomp\Model\RequestHandler" method="process"/>
+    </topic>
+    <topic name="stomp.multi.topic.queue.topic.z" request="Magento\TestModuleAsyncStomp\Model\AsyncTestData">
+        <handler name="stomp.processAsyncReqD" type="Magento\TestModuleAsyncStomp\Model\RequestHandler" method="process"/>
+    </topic>
 </config>

dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/queue_consumer.xml

@@ -10,4 +10,7 @@
     <!-- Consumers for wildcard queues -->
     <consumer name="stomp.wildcard.queue.one.consumer" connection="stomp" queue="stomp.wildcard.queue.one" handler="Magento\TestModuleAsyncStomp\Model\WildCardHandler::methodOne"/>
     <consumer name="stomp.wildcard.queue.two.consumer" connection="stomp" queue="stomp.wildcard.queue.two" handler="Magento\TestModuleAsyncStomp\Model\WildCardHandler::methodTwo"/>
+
+    <consumer name="stomp.queue.for.multiple.topics.test.y" queue="stomp.queue.for.multiple.topics.test.y" connection="stomp"/>
+    <consumer name="stomp.queue.for.multiple.topics.test.z" queue="stomp.queue.for.multiple.topics.test.z" connection="stomp"/>
 </config>

dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/queue_publisher.xml

@@ -19,4 +19,10 @@
         <connection name="stomp" exchange="magento" />
     </publisher>
 
+    <publisher topic="stomp.multi.topic.queue.topic.y" queue="stomp.queue.for.multiple.topics.test.y">
+        <connection name="stomp" exchange="magento" />
+    </publisher>
+    <publisher topic="stomp.multi.topic.queue.topic.z" queue="stomp.queue.for.multiple.topics.test.z">
+        <connection name="stomp" exchange="magento" />
+    </publisher>
 </config>

dev/tests/integration/_files/Magento/TestModuleAsyncStomp/etc/queue_topology.xml

@@ -8,6 +8,8 @@
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
     <exchange name="magento" connection="stomp" type="topic">
         <binding id="stomp.async.binding1" topic="stomp.multi.topic.queue.topic.c" destinationType="queue" destination="stomp.mixed.sync.and.async.queue"/>
+        <binding id="stomp.async.binding8" topic="stomp.multi.topic.queue.topic.y" destinationType="queue" destination="stomp.queue.for.multiple.topics.test.y"/>
+        <binding id="stomp.async.binding9" topic="stomp.multi.topic.queue.topic.z" destinationType="queue" destination="stomp.queue.for.multiple.topics.test.z"/>
     </exchange>
 </config>