Reduce unnecessary switches

apache · Oct 16, 2024 · 1ee9ba2 · 1ee9ba2
1 parent 6ab8dd2
commit 1ee9ba2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
@@ -542,7 +542,7 @@ private boolean processConsumeQueuesForTopic(ConcurrentMap<Integer, ConsumeQueue
  break;
  }
 
- if(i == minOffsetInQueue){
+ if (i == minOffsetInQueue) {
  earliestKcCqTime = kvCqUnit.getObject2();
  }
  if (!checkCqUnitEqual(kvCqUnit.getObject1(), fileCqUnit.getObject1())) {