shutdown the disk check service when the server closed

33b3688b · qqeasonchen · 0597823f · 33b3688b
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java ...n/java/org/apache/rocketmq/store/DefaultMessageStore.java +1 -1

未找到文件。
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -295,7 +295,7 @@ public class DefaultMessageStore implements MessageStore {
            this.shutdown = true;

            this.scheduledExecutorService.shutdown();
-
+            this.diskCheckScheduledExecutorService.shutdown();
            try {

                Thread.sleep(1000);