This is an automated email from the ASF dual-hosted git repository. aaronai pushed a commit to branch java in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit 17e83f7ab952e0b3ef30170f33a3bcc40c58ece8 Author: Aaron Ai <[email protected]> AuthorDate: Mon Dec 12 17:53:27 2022 +0800 Remove shutdown hook --- .../main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java index 4def65e5..00e30411 100644 --- a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java +++ b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java @@ -170,11 +170,6 @@ public abstract class ClientImpl extends AbstractIdleService implements Client, TimeUnit.SECONDS, new LinkedBlockingQueue<>(), new ThreadFactoryImpl("CommandExecutor", clientIdIndex)); - - Runtime.getRuntime().addShutdownHook(new Thread(() -> { - log.info("JVM shutdown hook is invoked, clientId={}, state={}", clientId, ClientImpl.this.state()); - ClientImpl.this.stopAsync().awaitTerminated(); - })); }
