Message queue consumers
The following table identifies all message queue consumers, describes what they do, and identifies the Admin system configuration settings associated with them:
Consumer and description
Adobe Commerce
Adobe Commerce with B2B
Magento Open Source
async.operations.all+
+
+
Creates messages for each individual task of a bulk operation, such as importing or exporting items, changing prices on a mass scale, and assigning products to a warehouse. Required when the Admin bulk operations option is set to Run asynchronously in the Admin system configuration settings.
codegeneratorProcessor+
+
+
Asynchronously generates coupons in the background. Required to use the batch coupon generation feature.
commerce.eventing.event.publish+
+
Checks for events that have been registered as priority in Adobe I/O Events for Adobe Commerce.
exportProcessor+
+
+
Prevents connection timeouts during the export of large data sets (for example 200,000 products).
inventoryQtyCounter+
+
Asynchronously corrects the stock index after an order is placed or a product is removed. Required when the Use deferred stock update option is enabled in the Admin configuration settings. See Performance Best Practices.
inventory.source.items.cleanup+
+
+
Asynchronously deletes source items by product SKU when a product is removed. Required when the Synchronize with Catalog stock option is enabled in the Admin system configuration settings.
inventory.mass.update+
+
+
Asynchronously processes legacy stock items, updates legacy stock items, updates default source items, and reindexes inventory for specific product SKUs. Required when the Run asynchronously bulk operation is enabled in the Admin system configuration settings.
inventory.reservations.cleanup+
+
+
Asynchronously deletes reservations by product SKU after a product is removed. Required when the Synchronize with Catalog stock option is enabled in the Admin system configuration settings.
inventory.reservations.update+
+
+
Asynchronously updates reservations by product SKU after a product is removed. Required when the Synchronize with Catalog stock option is enabled in the Admin system configuration settings.
inventory.reservations.updateSalabilityStatus+
+
+
Asynchronously updates the salable quantity of each product assigned to a stock. This consumer should always be up and running if you are using Inventory Management.
inventory.indexer.sourceItem+
+
+
Asynchronously reindexes source items. Required when the Stock/Source reindex strategy is set to “asynchronous” in the Admin system configuration settings.
inventory.indexer.stock+
+
+
Asynchronously reindexes stock. Required when the Stock/Source reindex strategy is set to “asynchronous” in the Admin system configuration settings.
matchCustomerSegmentProcessor+
+
Creates a temporary database table, moves each customer segment into it, deletes all segments that match the segment ID, and copies them to the customer segments using the segment ID as the indicator. This is all done in a transaction so that if something fails, it rolls back the transaction to what it was before this executed. After a transaction, the consumer drops the temporary table.
media.content.synchronization+
+
+
Ensures that links to assigned media for products, categories, CMS blocks, and CMS pages are correctly assigned to the asset. Removes old assets that are no longer used.
media.gallery.renditions.update+
+
+
Generates and validates media asset paths. The absolute path to an asset is determined by where it sits on the server from inside the media directory. Images are resized (if necessary) and copied to the media directory inside the generated path.
media.gallery.synchronization+
+
+
Imports image files to the
media_gallery_asset database table.media.storage.catalog.image.resize+
+
+
Asynchronously resizes catalog images.
negotiableQuotePriceUpdate+
Updates prices for negotiable quotes. Required when the Quotes option is enabled in the Admin system configuration settings.
placeOrderProcessor+
+
Asynchronously processes orders, which mark orders as received, places them in the message queue, and processes them in a first-in-first-out basis. Considered a best practice for improving the number of orders that can be processed because customers do not need to wait for backend processes to complete before seeing a success message.
product_action_attribute.update+
+
+
Asynchronously writes changes to product attributes in the database after using the Admin to make updates.
product_action_attribute.website.update+
+
+
Asynchronously writes changes to product attributes for a specific store view in the database after using the Admin to make updates.
product_alert+
+
+
Sends notification emails to customers about product price and inventory changes. Required when the Required when the Product Alerts option is enabled in the Admin system configuration settings.
purchaseorder.toorder+
Converts purchase order to order. Required when the Purchase Order option is enabled in the Admin system configuration settings.
purchaseorder.transactional.email+
Sends purchase order emails. Required when the Purchase Order option is enabled in the Admin system configuration settings.
purchaseorder.validation+
Validates purchase order against relevant approval rules. Required when the Purchase Order option is enabled in the Admin system configuration settings.
Asynchronously saves store configuration changes by placing save jobs in a message queue, which can improve performance on deployments that contain a large number of store-level configurations. Required to use the
AsyncConfig module.sales.rule.update.coupon.usage+
+
+
Prevents the issue where single-use coupons can be used multiple times.
sharedCatalogUpdateCategoryPermissions+
Updates categories assigned to a shared catalog category. Required when the Shared Catalogs option is enabled in the Admin system configuration settings.
sharedCatalogUpdatePrice+
Updates price for each product in a shared catalog. Required when the Shared Catalogs option is enabled in the Admin system configuration settings.
quoteItemCleaner+
+
Deletes invalid or inactive price quotes when a product is deleted from the catalog or removed from the cart. Required when the Quotes option is enabled in the Admin system configuration settings.
sales.rule.quote.trigger.recollect+
+
+
Updates active shopping carts to reflect the changes in the cart price rule. Required when updating Catalog price rules.
386822bd-e32c-40a8-81c2-ed90ad1e198c