honor queue_consumer.xml maxMessages

AntonEvers · AntonEvers · commit af828b7261a8 · 2020-07-04T17:58:50.000+02:00
diff --git a/app/code/Magento/MessageQueue/Model/Cron/ConsumersRunner.php b/app/code/Magento/MessageQueue/Model/Cron/ConsumersRunner.php
@@ -121,7 +121,7 @@ public function run()
             ];
 
             if ($maxMessages) {
-                $arguments[] = '--max-messages=' . $maxMessages;
+                $arguments[] = '--max-messages=' . min($consumer->getMaxMessages() ?? $maxMessages, $maxMessages);
             }
 
             $command = $php . ' ' . BP . '/bin/magento queue:consumers:start %s %s'

Original file line number	Diff line number	Diff line change
`@@ -121,7 +121,7 @@ public function run()`
`121`	`121`	`];`
`122`	`122`
`123`	`123`	`if ($maxMessages) {`
`124`		`- $arguments[] = '--max-messages=' . $maxMessages;`
	`124`	`+ $arguments[] = '--max-messages=' . min($consumer->getMaxMessages() ?? $maxMessages, $maxMessages);`
`125`	`125`	`}`
`126`	`126`
`127`	`127`	`$command = $php . ' ' . BP . '/bin/magento queue:consumers:start %s %s'`