Fix the metric of the time wheel was incorrectly calculated

apache · May 13, 2024 · e531415 · e531415
1 parent db1e41e
commit e531415
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
@@ -1560,7 +1560,7 @@ public void run() {
                                 if (needDelete(tr.getMagic()) && !needRoll(tr.getMagic())) {
                                     //Clearing is performed once in each round.
                                     //The deletion message is received first and the common message is received once
-                                    if(!isRound){
+                                    if (!isRound) {
                                         isRound = true;
                                         for (MessageExt messageExt: avoidDeleteLose.values()) {
                                             addMetric(messageExt, 1);
@@ -1580,7 +1580,7 @@ public void run() {
                                         LOGGER.warn("No uniqueKey for msg:{}", msgExt);
                                     }
                                     //Mark ready for next round
-                                    if(isRound){
+                                    if (isRound) {
                                         isRound = false;
                                     }
                                     if (null != uniqueKey && tr.getDeleteList() != null && tr.getDeleteList().size() > 0 && tr.getDeleteList().contains(uniqueKey)) {