[ISSUE #2729] Replace with Math.min method call

af8a9648 · drgnchan · GitHub · 7680063f · af8a9648
隐藏空白更改
内联并排

Showing with 1 addition and 3 deletion

broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java .../org/apache/rocketmq/broker/topic/TopicConfigManager.java +1 -3

未找到文件。
--- a/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
@@ -176,9 +176,7 @@ public class TopicConfigManager extends ConfigManager {
                        if (PermName.isInherited(defaultTopicConfig.getPerm())) {
                            topicConfig = new TopicConfig(topic);
-                            int queueNums =
+                            int queueNums = Math.min(clientDefaultTopicQueueNums, defaultTopicConfig.getWriteQueueNums());
-                                clientDefaultTopicQueueNums > defaultTopicConfig.getWriteQueueNums() ? defaultTopicConfig
-                                    .getWriteQueueNums() : clientDefaultTopicQueueNums;
                            if (queueNums < 0) {
                                queueNums = 0;