shutdown transactionalMessageCheckService

0fff4a8d · DESKTOP-E3RLCKV\chixuan · 289f0d2e · 0fff4a8d
隐藏空白更改
内联并排

Showing with 4 addition and 0 deletion

broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java ...ain/java/org/apache/rocketmq/broker/BrokerController.java +4 -0

未找到文件。
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -741,6 +741,10 @@ public class BrokerController {
        if (this.fileWatchService != null) {
            this.fileWatchService.shutdown();
        }
+        
+        if (this.transactionalMessageCheckService != null) {
+            this.transactionalMessageCheckService.shutdown(false);
+        }
    }

    private void unregisterBrokerAll() {