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'