fix

qianye1001 · qianye1001 · commit b1be079be388 · 2026-03-03T14:03:16.000+08:00
diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushConsumerImpl.java b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushConsumerImpl.java
@@ -499,7 +499,7 @@ int cacheMessageCountThresholdPerQueue() {
         }
         // If a per-queue limit is explicitly configured, use it directly.
         if (maxCacheMessageCountEachQueue > 0) {
-            return maxCacheMessageCountEachQueue;
+            return Math.max(maxCacheMessageCountEachQueue, maxCacheMessageCount / size);
         }
         return Math.max(1, maxCacheMessageCount / size);
     }

Original file line number	Diff line number	Diff line change
`@@ -499,7 +499,7 @@ int cacheMessageCountThresholdPerQueue() {`
`499`	`499`	`}`
`500`	`500`	`// If a per-queue limit is explicitly configured, use it directly.`
`501`	`501`	`if (maxCacheMessageCountEachQueue > 0) {`
`502`		`- return maxCacheMessageCountEachQueue;`
	`502`	`+ return Math.max(maxCacheMessageCountEachQueue, maxCacheMessageCount / size);`
`503`	`503`	`}`
`504`	`504`	`return Math.max(1, maxCacheMessageCount / size);`
`505`	`505`	`}`