Skip to content

Commit 8e8b604

Browse files
committed
MCP-826: Use RabbitMQ for all consumers if AMQP is set in deployment config
- Remove topic type from exchange in topology because topic is a default value of exchange type;
1 parent 45a5357 commit 8e8b604

File tree

10 files changed

+10
-10
lines changed

10 files changed

+10
-10
lines changed

app/code/Magento/Catalog/etc/queue_topology.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
*/
77
-->
88
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
9-
<exchange name="magento" type="topic">
9+
<exchange name="magento">
1010
<binding id="updateBinding" topic="product_action_attribute.update" destination="product_action_attribute.update"/>
1111
<binding id="updateBindingWebsite" topic="product_action_attribute.website.update" destination="product_action_attribute.website.update"/>
1212
</exchange>

app/code/Magento/ImportExport/etc/queue_topology.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
*/
77
-->
88
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
9-
<exchange name="magento" type="topic">
9+
<exchange name="magento">
1010
<binding id="exportBinding" topic="import_export.export" destination="export"/>
1111
</exchange>
1212
</config>

app/code/Magento/MediaContentSynchronization/etc/queue_topology.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
-->
88
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
99
xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
10-
<exchange name="magento" type="topic">
10+
<exchange name="magento">
1111
<binding id="MediaContentSynchronization" topic="media.content.synchronization" destination="media.content.synchronization"/>
1212
</exchange>
1313
</config>

app/code/Magento/MediaGalleryRenditions/etc/queue_topology.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
-->
88
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
99
xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
10-
<exchange name="magento" type="topic">
10+
<exchange name="magento">
1111
<binding id="MediaGalleryRenditions" topic="media.gallery.renditions.update" destination="media.gallery.renditions.update"/>
1212
</exchange>
1313
</config>

app/code/Magento/MediaGallerySynchronization/etc/queue_topology.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
-->
88
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
99
xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
10-
<exchange name="magento" type="topic">
10+
<exchange name="magento">
1111
<binding id="MediaGallerySynchronization" topic="media.gallery.synchronization" destination="media.gallery.synchronization"/>
1212
</exchange>
1313
</config>

app/code/Magento/MediaStorage/etc/queue_topology.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
*/
77
-->
88
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
9-
<exchange name="magento" type="topic">
9+
<exchange name="magento">
1010
<binding id="imageResizeBinding" topic="media.storage.catalog.image.resize" destination="media.storage.catalog.image.resize"/>
1111
</exchange>
1212
</config>

app/code/Magento/MessageQueue/Setup/ConfigOptionsList.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ class ConfigOptionsList implements ConfigOptionsListInterface
2323
* Input key for the option
2424
*/
2525
public const INPUT_KEY_QUEUE_CONSUMERS_WAIT_FOR_MESSAGES ='consumers-wait-for-messages';
26-
public const INPUT_KEY_QUEUE_DEFAULT_CONNECTION ='default-connection';
26+
public const INPUT_KEY_QUEUE_DEFAULT_CONNECTION ='queue-default-connection';
2727

2828
/**
2929
* Path to the values in the deployment config

app/code/Magento/SalesRule/etc/queue_topology.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
*/
77
-->
88
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
9-
<exchange name="magento" type="topic">
9+
<exchange name="magento">
1010
<binding id="codegeneratorBinding" topic="sales_rule.codegenerator" destination="codegenerator"/>
1111
<binding id="couponUsageBinding" topic="sales.rule.update.coupon.usage" destination="sales.rule.update.coupon.usage"/>
1212
</exchange>

app/code/Magento/WebapiAsync/etc/queue_topology.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
*/
77
-->
88
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/topology.xsd">
9-
<exchange name="magento" type="topic" connection="amqp">
9+
<exchange name="magento" connection="amqp">
1010
<binding id="async.operations.all" topic="async.#" destination="async.operations.all"/>
1111
</exchange>
1212
</config>

dev/tests/integration/etc/post-install-setup-command-config.php.dist

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ return [
1313
'--remote-storage-driver' => 'aws-s3',
1414
'--remote-storage-bucket' => 'myBucket',
1515
'--remote-storage-region' => 'us-east-1',
16-
'--default-connection' => 'db'
16+
'--queue-default-connection' => 'db'
1717
]
1818
]
1919
*/

0 commit comments

Comments
 (0)