From 334c33e9a4924adea58e73405c236de0d5ee0317 Mon Sep 17 00:00:00 2001
From: kris20030907 <3185633428@qq.com>
Date: Sat, 21 Mar 2026 21:40:02 +0800
Subject: [PATCH 1/2] enhance: remove unused fetchRemoteConfigExecutorService
in MQClientInstance
---
.../rocketmq/client/impl/factory/MQClientInstance.java | 6 ------
1 file changed, 6 deletions(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
index e10807cf50b..22a05ba1aea 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
@@ -135,12 +135,6 @@ public class MQClientInstance {
private final Set brokerSupportV2HeartbeatSet = new HashSet<>();
private final ConcurrentMap brokerAddrHeartbeatFingerprintTable = new ConcurrentHashMap<>();
private final ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor(r -> new Thread(r, "MQClientFactoryScheduledThread"));
- private final ScheduledExecutorService fetchRemoteConfigExecutorService = Executors.newSingleThreadScheduledExecutor(new ThreadFactory() {
- @Override
- public Thread newThread(Runnable r) {
- return new Thread(r, "MQClientFactoryFetchRemoteConfigScheduledThread");
- }
- });
private final PullMessageService pullMessageService;
private final RebalanceService rebalanceService;
private final DefaultMQProducer defaultMQProducer;
From 00625cc67cd2936fd46193f1c37de5f610acbb98 Mon Sep 17 00:00:00 2001
From: Kris20030907 <3185633428@qq.com>
Date: Tue, 31 Mar 2026 16:03:24 +0800
Subject: [PATCH 2/2] fix: remove useless import.
---
.../apache/rocketmq/client/impl/factory/MQClientInstance.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
index 22a05ba1aea..cd45fed2a3a 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
@@ -86,7 +86,6 @@
import java.util.concurrent.Executors;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.locks.Lock;