Allow configuration in queue_consumer.xml to be higher than default

baudeval · web-flow · commit e36f449a4e5d · 2025-07-29T14:56:05.000+02:00
diff --git 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'

Original file line number	Diff line number	Diff line change
`@@ -139,8 +139,7 @@ public function run(): void`
`139`	`139`	`];`
`140`	`140`
`141`	`141`	`if ($maxMessages) {`
`142`		`- $arguments[] =`
`143`		`- '--max-messages=' . min($consumer->getMaxMessages() ?? $maxMessages, $maxMessages);`
	`142`	`+ $arguments[] = '--max-messages=' . ($consumer->getMaxMessages() ?? $maxMessages);`
`144`	`143`	`}`
`145`	`144`
`146`	`145`	`$command = $php . ' ' . BP . '/bin/magento queue:consumers:start %s %s'`
`@@ -155,7 +154,7 @@ public function run(): void`
`155`	`154`	`];`
`156`	`155`
`157`	`156`	`if ($maxMessages) {`
`158`		`- $arguments[] = '--max-messages=' . min($consumer->getMaxMessages() ?? $maxMessages, $maxMessages);`
	`157`	`+ $arguments[] = '--max-messages=' . ($consumer->getMaxMessages() ?? $maxMessages);`
`159`	`158`	`}`
`160`	`159`
`161`	`160`	`$command = $php . ' ' . BP . '/bin/magento queue:consumers:start %s %s'`