fix thread lead with rocketmq consumer start and shutdown frequently

willimpo · willimpo · commit 508579b09f73 · 2023-04-12T22:55:56.000+08:00
diff --git a/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java b/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
@@ -106,7 +106,9 @@ public void start() {
 
     @Override
     public void shutdown(long awaitTerminateMillis) {
-
+        this.scheduledExecutorService.shutdown();
+        org.apache.rocketmq.common.utils.ThreadUtils.shutdownGracefully(this.consumeExecutor, awaitTerminateMillis, TimeUnit.MILLISECONDS);
+        this.cleanExpireMsgExecutors.shutdown();
     }
 
     public void shutdown() {

Original file line number	Diff line number	Diff line change
`@@ -106,7 +106,9 @@ public void start() {`
`106`	`106`
`107`	`107`	`@Override`
`108`	`108`	`public void shutdown(long awaitTerminateMillis) {`
`109`		`-`
	`109`	`+ this.scheduledExecutorService.shutdown();`
	`110`	`+ org.apache.rocketmq.common.utils.ThreadUtils.shutdownGracefully(this.consumeExecutor, awaitTerminateMillis, TimeUnit.MILLISECONDS);`
	`111`	`+ this.cleanExpireMsgExecutors.shutdown();`
`110`	`112`	`}`
`111`	`113`
`112`	`114`	`public void shutdown() {`