From b55842131d57dbedbf689f9c07087ac669e5695a Mon Sep 17 00:00:00 2001 From: yanhom Date: Sun, 22 Oct 2023 21:43:50 +0800 Subject: [PATCH] Optimized shutdown original thread pool after with proxy enhancement --- .../dynamictp/adapter/rocketmq/RocketMqDtpAdapter.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/adapter/adapter-rocketmq/src/main/java/org/dromara/dynamictp/adapter/rocketmq/RocketMqDtpAdapter.java b/adapter/adapter-rocketmq/src/main/java/org/dromara/dynamictp/adapter/rocketmq/RocketMqDtpAdapter.java index 177796c14..aa1a6df8a 100644 --- a/adapter/adapter-rocketmq/src/main/java/org/dromara/dynamictp/adapter/rocketmq/RocketMqDtpAdapter.java +++ b/adapter/adapter-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));