fix test

apache · Jan 17, 2025 · 4823690 · 4823690
1 parent 8f6efef
commit 4823690
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/store/src/main/java/org/apache/rocketmq/store/timer/rocksdb/TimerMessageRocksDBStore.java b/store/src/main/java/org/apache/rocketmq/store/timer/rocksdb/TimerMessageRocksDBStore.java
@@ -402,6 +402,9 @@ public void run() {
             TimerMessageRocksDBStore.log.info(this.getServiceName() + " service start");
             while (!this.isStopped() || !dequeuePutQueue.isEmpty()) {
                 try {
+                    if (!allowDequeue) {
+                        continue;
+                    }
                     List<TimerMessageRecord> timerMessageRecord = dequeuePutQueue.poll(100L * precisionMs / 1000, TimeUnit.MILLISECONDS);
                     if (null == timerMessageRecord || timerMessageRecord.isEmpty()) {
                         continue;