Fix }

901e06af · dongeforever · cdf40428 · 901e06af
显示空白变更内容
内联并排

Showing with 1 addition and 0 deletion

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

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

        if (this.endTransactionExecutor != null) {
            this.endTransactionExecutor.shutdown();