Skip to content

Commit

Permalink
Drop MySQL support for message queueing
Browse files Browse the repository at this point in the history
  • Loading branch information
supercid committed Jun 4, 2024
1 parent 782db1b commit da798c1
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 7 deletions.
4 changes: 2 additions & 2 deletions etc/queue.xml
Original file line number Diff line number Diff line change
Expand Up @@ -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="db">
<broker topic="nosto_product_sync.update" exchange="magento-db" 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="db">
<broker topic="nosto_product_sync.delete" exchange="magento-db" type="amqp">
<queue name="nosto_product_sync.delete"
consumer="nosto_product_sync.delete"
consumerInstance="Magento\Framework\MessageQueue\Consumer"
Expand Down
4 changes: 2 additions & 2 deletions etc/queue_consumer.xml
Original file line number Diff line number Diff line change
Expand Up @@ -37,13 +37,13 @@
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/consumer.xsd">
<consumer name="nosto_product_sync.update"
queue="nosto_product_sync.update"
connection="db"
connection="amqp"
maxMessages="20"
consumerInstance="Magento\Framework\MessageQueue\Consumer"
handler="Nosto\Tagging\Model\Service\Sync\Upsert\AsyncBulkConsumer::processOperation"/>
<consumer name="nosto_product_sync.delete"
queue="nosto_product_sync.delete"
connection="db"
connection="amqp"
maxMessages="100"
consumerInstance="Magento\Framework\MessageQueue\Consumer"
handler="Nosto\Tagging\Model\Service\Sync\Delete\AsyncBulkConsumer::processOperation"/>
Expand Down
4 changes: 2 additions & 2 deletions etc/queue_publisher.xml
Original file line number Diff line number Diff line change
Expand Up @@ -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="db" exchange="magento-db"/>
<connection name="amqp" exchange="magento-db"/>
</publisher>
<publisher topic="nosto_product_sync.delete">
<connection name="db" exchange="magento-db"/>
<connection name="amqp" exchange="magento-db"/>
</publisher>
</config>
2 changes: 1 addition & 1 deletion etc/queue_topology.xml
Original file line number Diff line number Diff line change
Expand Up @@ -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="db">
<exchange name="magento-db" 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>
Expand Down

0 comments on commit da798c1

Please sign in to comment.