fix test

apache · Jan 17, 2025 · 8f6efef · 8f6efef
1 parent 92f210a
commit 8f6efef
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -101,7 +101,7 @@ public class TimerMessageRocksDBStore {
 
     ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor();
     private volatile long commitOffset;
-    private boolean allowDequeue;
+    private boolean allowDequeue = true;
 
     public TimerMessageRocksDBStore(final MessageStore messageStore, final MessageStoreConfig storeConfig,
         TimerMetrics timerMetrics, final BrokerStatsManager brokerStatsManager) {