[rocketmq-clients] branch java updated: Remove shutdown hook

[aaronai]

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


The following commit(s) were added to refs/heads/java by this push:
     new 027d6ef3 Remove shutdown hook
027d6ef3 is described below

commit 027d6ef32f14f95dee6734c574d0eba3da10de36
Author: Aaron Ai <yangkun....@gmail.com>
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 55292619..c475bfc0 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();
-        }));
     }