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 4ac96c5383f58522014f7aeb789badce1e4de027..e7ef46d0c61607e8d81eb478ecdcec373947e6f2 100644 --- 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();