Fix UTs

apache · Oct 24, 2023 · ae2c2b1 · ae2c2b1
1 parent dbc6411
commit ae2c2b1
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
@@ -294,11 +294,11 @@ public void recover() {
         ConsumeQueueInterface cq = this.messageStore.getConsumeQueue(TIMER_TOPIC, 0);
 
         // Correction based consume queue
-        if (currQueueOffset < cq.getMinOffsetInQueue()) {
+        if (cq != null && currQueueOffset < cq.getMinOffsetInQueue()) {
             LOGGER.warn("Timer currQueueOffset:{} is smaller than minOffsetInQueue:{}",
                 currQueueOffset, cq.getMinOffsetInQueue());
             currQueueOffset = cq.getMinOffsetInQueue();
-        } else if (currQueueOffset > cq.getMaxOffsetInQueue()) {
+        } else if (cq != null && currQueueOffset > cq.getMaxOffsetInQueue()) {
             LOGGER.warn("Timer currQueueOffset:{} is larger than maxOffsetInQueue:{}",
                 currQueueOffset, cq.getMaxOffsetInQueue());
             currQueueOffset = cq.getMaxOffsetInQueue();