File tree Expand file tree Collapse file tree 1 file changed +0
-7
lines changed
client/src/main/java/org/apache/rocketmq/client/impl/factory Expand file tree Collapse file tree 1 file changed +0
-7
lines changed Original file line number Diff line number Diff line change 8686import java .util .concurrent .Executors ;
8787import java .util .concurrent .RejectedExecutionException ;
8888import java .util .concurrent .ScheduledExecutorService ;
89- import java .util .concurrent .ThreadFactory ;
9089import java .util .concurrent .TimeUnit ;
9190import java .util .concurrent .atomic .AtomicLong ;
9291import java .util .concurrent .locks .Lock ;
@@ -135,12 +134,6 @@ public class MQClientInstance {
135134 private final Set <String /* Broker address */ > brokerSupportV2HeartbeatSet = new HashSet <>();
136135 private final ConcurrentMap <String , Integer > brokerAddrHeartbeatFingerprintTable = new ConcurrentHashMap <>();
137136 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- });
144137 private final PullMessageService pullMessageService ;
145138 private final RebalanceService rebalanceService ;
146139 private final DefaultMQProducer defaultMQProducer ;
You can’t perform that action at this time.
0 commit comments