Skip to content

Commit

Permalink
Adding back the connection attribute to the queue topology, consumer …
Browse files Browse the repository at this point in the history
…and publisher to avoid introducing the breaking change.
  • Loading branch information
khushboo-singhvi committed Dec 30, 2024
1 parent 3ab803c commit 66302d1
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 2 deletions.
1 change: 1 addition & 0 deletions etc/queue_consumer.xml
Original file line number Diff line number Diff line change
Expand Up @@ -3,5 +3,6 @@
xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/consumer.xsd">
<consumer name="adyen.notification"
queue="adyen.notification"
connection="amqp"
handler="Adyen\Payment\Model\Queue\Notification\Consumer::execute"/>
</config>
4 changes: 3 additions & 1 deletion etc/queue_publisher.xml
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
<?xml version="1.0"?>
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/publisher.xsd">
<publisher topic="adyen.notification"/>
<publisher topic="adyen.notification">
<connection name="amqp" exchange="magento"/>
</publisher>
</config>
2 changes: 1 addition & 1 deletion etc/queue_topology.xml
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
<?xml version="1.0"?>
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
<exchange name="magento" type="topic">
<exchange name="magento" type="topic" connection="amqp">
<binding id="NotificationBinding"
topic="adyen.notification"
destinationType="queue"
Expand Down

0 comments on commit 66302d1

Please sign in to comment.