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 <[email protected]> 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
