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 @@ -135,12 +135,6 @@ public class MQClientInstance {
135135 private final Set <String /* Broker address */ > brokerSupportV2HeartbeatSet = new HashSet <>();
136136 private final ConcurrentMap <String , Integer > brokerAddrHeartbeatFingerprintTable = new ConcurrentHashMap <>();
137137 private final ScheduledExecutorService scheduledExecutorService = Executors .newSingleThreadScheduledExecutor (r -> new Thread (r , "MQClientFactoryScheduledThread" ));
138- private final ScheduledExecutorService fetchRemoteConfigExecutorService = Executors .newSingleThreadScheduledExecutor (new ThreadFactory () {
139- @ Override
140- public Thread newThread (Runnable r ) {
141- return new Thread (r , "MQClientFactoryFetchRemoteConfigScheduledThread" );
142- }
143- });
144138 private final PullMessageService pullMessageService ;
145139 private final RebalanceService rebalanceService ;
146140 private final DefaultMQProducer defaultMQProducer ;
You can’t perform that action at this time.
0 commit comments