You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2023/02/14 05:50:58 UTC
[rocketmq] 03/18: Fixed the infinite loop bug and useless import
This is an automated email from the ASF dual-hosted git repository.
zhouxzhan pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 8a3c7ffde4e160324bbcf05d8708ef55bd1e4c93
Author: nowinkey <no...@tom.com>
AuthorDate: Fri Jan 20 12:48:36 2023 +0800
Fixed the infinite loop bug and useless import
---
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
index 10f54a36f..97a0ee835 100644
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -54,7 +54,6 @@ import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentLinkedQueue;
-import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.Supplier;
import org.apache.commons.lang3.StringUtils;
@@ -3086,7 +3085,7 @@ public class DefaultMessageStore implements MessageStore {
this.reputFromOffset);
}
- this.shutdown();
+ super.shutdown();
}
@Override