Rename default exchange name to magento-amqp

Nosto · Jun 4, 2024 · 4806432 · 4806432
1 parent da798c1
commit 4806432
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/etc/queue.xml b/etc/queue.xml
@@ -35,13 +35,13 @@
   -->
 <!--suppress XmlUnboundNsPrefix -->
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/queue.xsd">
-    <broker topic="nosto_product_sync.update" exchange="magento-db" type="amqp">
+    <broker topic="nosto_product_sync.update" exchange="magento-amqp" type="amqp">
         <queue name="nosto_product_sync.update"
                consumer="nosto_product_sync.update"
                consumerInstance="Magento\Framework\MessageQueue\Consumer"
                handler="Nosto\Tagging\Model\Service\Sync\Upsert\AsyncBulkConsumer::process"/>
     </broker>
-    <broker topic="nosto_product_sync.delete" exchange="magento-db" type="amqp">
+    <broker topic="nosto_product_sync.delete" exchange="magento-amqp" type="amqp">
         <queue name="nosto_product_sync.delete"
                consumer="nosto_product_sync.delete"
                consumerInstance="Magento\Framework\MessageQueue\Consumer"

diff --git a/etc/queue_publisher.xml b/etc/queue_publisher.xml
@@ -36,9 +36,9 @@
 <!--suppress XmlUnboundNsPrefix -->
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/publisher.xsd">
     <publisher topic="nosto_product_sync.update">
-        <connection name="amqp" exchange="magento-db"/>
+        <connection name="amqp" exchange="magento-amqp"/>
     </publisher>
     <publisher topic="nosto_product_sync.delete">
-        <connection name="amqp" exchange="magento-db"/>
+        <connection name="amqp" exchange="magento-amqp"/>
     </publisher>
 </config>
diff --git a/etc/queue_topology.xml b/etc/queue_topology.xml
@@ -35,7 +35,7 @@
   -->
 <!--suppress XmlUnboundNsPrefix -->
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
-    <exchange name="magento-db" type="topic" connection="amqp">
+    <exchange name="magento-amqp" type="topic" connection="amqp">
         <binding id="updateBindingUpsert" topic="nosto_product_sync.update" destinationType="queue" destination="nosto_product_sync.update"/>
         <binding id="updateBindingDelete" topic="nosto_product_sync.delete" destinationType="queue" destination="nosto_product_sync.delete"/>
     </exchange>