From e36f449a4e5d32a15bf01f7b77bd1c98f8515521 Mon Sep 17 00:00:00 2001 From: baudeval <58520315+baudeval@users.noreply.github.com> Date: Tue, 29 Jul 2025 14:56:05 +0200 Subject: [PATCH] Allow configuration in queue_consumer.xml to be higher than default --- app/code/Magento/MessageQueue/Model/Cron/ConsumersRunner.php | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/app/code/Magento/MessageQueue/Model/Cron/ConsumersRunner.php b/app/code/Magento/MessageQueue/Model/Cron/ConsumersRunner.php index cb320e98d28c5..818da53285b63 100644 --- a/app/code/Magento/MessageQueue/Model/Cron/ConsumersRunner.php +++ b/app/code/Magento/MessageQueue/Model/Cron/ConsumersRunner.php @@ -139,8 +139,7 @@ public function run(): void ]; if ($maxMessages) { - $arguments[] = - '--max-messages=' . min($consumer->getMaxMessages() ?? $maxMessages, $maxMessages); + $arguments[] = '--max-messages=' . ($consumer->getMaxMessages() ?? $maxMessages); } $command = $php . ' ' . BP . '/bin/magento queue:consumers:start %s %s' @@ -155,7 +154,7 @@ public function run(): void ]; if ($maxMessages) { - $arguments[] = '--max-messages=' . min($consumer->getMaxMessages() ?? $maxMessages, $maxMessages); + $arguments[] = '--max-messages=' . ($consumer->getMaxMessages() ?? $maxMessages); } $command = $php . ' ' . BP . '/bin/magento queue:consumers:start %s %s'