Skip to content

Commit ab62de6

Browse files
authored
[ISSUE apache#2729] Replace with Math.min method call
1 parent 0f2c92f commit ab62de6

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -176,9 +176,7 @@ public TopicConfig createTopicInSendMessageMethod(final String topic, final Stri
176176
if (PermName.isInherited(defaultTopicConfig.getPerm())) {
177177
topicConfig = new TopicConfig(topic);
178178

179-
int queueNums =
180-
clientDefaultTopicQueueNums > defaultTopicConfig.getWriteQueueNums() ? defaultTopicConfig
181-
.getWriteQueueNums() : clientDefaultTopicQueueNums;
179+
int queueNums = Math.min(clientDefaultTopicQueueNums, defaultTopicConfig.getWriteQueueNums());
182180

183181
if (queueNums < 0) {
184182
queueNums = 0;

0 commit comments

Comments
 (0)