File tree Expand file tree Collapse file tree
client/src/main/java/org/apache/rocketmq/client/impl/factory Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -134,12 +134,6 @@ public class MQClientInstance {
134134 private final Set <String /* Broker address */ > brokerSupportV2HeartbeatSet = new HashSet <>();
135135 private final ConcurrentMap <String , Integer > brokerAddrHeartbeatFingerprintTable = new ConcurrentHashMap <>();
136136 private final ScheduledExecutorService scheduledExecutorService = Executors .newSingleThreadScheduledExecutor (r -> new Thread (r , "MQClientFactoryScheduledThread" ));
137- private final ScheduledExecutorService fetchRemoteConfigExecutorService = Executors .newSingleThreadScheduledExecutor (new ThreadFactory () {
138- @ Override
139- public Thread newThread (Runnable r ) {
140- return new Thread (r , "MQClientFactoryFetchRemoteConfigScheduledThread" );
141- }
142- });
143137 private final PullMessageService pullMessageService ;
144138 private final RebalanceService rebalanceService ;
145139 private final DefaultMQProducer defaultMQProducer ;
You can’t perform that action at this time.
0 commit comments