From b44f14dd0caa4fcf73853691a6ddfd5681ee51f6 Mon Sep 17 00:00:00 2001
From: kris20030907 <3185633428@qq.com>
Date: Sat, 21 Mar 2026 21:40:02 +0800
Subject: [PATCH] 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 e0b28fef646..43ea2978e4d 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
@@ -134,12 +134,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;