Optimized shutdown original thread pool after with proxy enhancement

dromara · Oct 22, 2023 · b558421 · b558421
1 parent c9730b8
commit b558421
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...ter-rocketmq/src/main/java/org/dromara/dynamictp/adapter/rocketmq/RocketMqDtpAdapter.java b/...ter-rocketmq/src/main/java/org/dromara/dynamictp/adapter/rocketmq/RocketMqDtpAdapter.java
@@ -36,8 +36,6 @@
 import java.util.Objects;
 import java.util.concurrent.ThreadPoolExecutor;
 
-import static org.dromara.dynamictp.core.support.DtpLifecycleSupport.shutdownGracefulAsync;
-
 /**
  * RocketMqDtpAdapter related
  *
@@ -114,7 +112,7 @@ public void adaptProducerExecutors() {
             if (Objects.nonNull(executor)) {
                 ThreadPoolExecutorProxy proxy = new ThreadPoolExecutorProxy(executor);
                 producer.setAsyncSenderExecutor(proxy);
-                shutdownGracefulAsync(executor, getTpPrefix(), 5);
+                shutdownOriginalExecutor(executor);
 
                 String proKey = TP_PREFIX + "#producer#" + defaultMQProducer.getProducerGroup();
                 executors.put(proKey, new ExecutorWrapper(proKey, proxy));