From 35b7847fe26adbfd26007531b7d4abf65b561bd3 Mon Sep 17 00:00:00 2001 From: xiaochangbai <704566072@qq.com> Date: Sat, 27 May 2023 14:00:26 +0800 Subject: [PATCH] [ISSUE #6819] Rename brokerHeartbeatExecutorService executorService name --- .../main/java/org/apache/rocketmq/broker/BrokerController.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java index 329bd86c0c1..8560bde9faa 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java @@ -545,7 +545,7 @@ protected void initializeResources() { this.syncBrokerMemberGroupExecutorService = new ScheduledThreadPoolExecutor(1, new ThreadFactoryImpl("BrokerControllerSyncBrokerScheduledThread", getBrokerIdentity())); this.brokerHeartbeatExecutorService = new ScheduledThreadPoolExecutor(1, - new ThreadFactoryImpl("rokerControllerHeartbeatScheduledThread", getBrokerIdentity())); + new ThreadFactoryImpl("BrokerControllerHeartbeatScheduledThread", getBrokerIdentity())); this.topicQueueMappingCleanService = new TopicQueueMappingCleanService(this); }