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 f45674d6e461e623e08a769ef0fcd1372c1ee05e..78f46a03144e5b41564fbd7163c67905a47381f3 100644 --- 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() {