Optimize RocksDB CQ shutdown when using DoubleWriteCQ apache#9212

yx9o · Feb 28, 2025 · 66d4a26 · 66d4a26
1 parent 5936695
commit 66d4a26
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -517,7 +517,7 @@ public void shutdown() {
             if (this.compactionService != null) {
                 this.compactionService.shutdown();
             }
-            if (messageStoreConfig.isRocksdbCQDoubleWriteEnable() && this.rocksDBMessageStore != null) {
+            if (this.rocksDBMessageStore != null && this.rocksDBMessageStore.consumeQueueStore != null) {
                 this.rocksDBMessageStore.consumeQueueStore.shutdown();
             }
             this.flushConsumeQueueService.shutdown();