From 0fff4a8d84086dc64c2c6df398e6f651cffdd3a8 Mon Sep 17 00:00:00 2001
From: "DESKTOP-E3RLCKV\\chixuan" <xuan.chi@ymm56.com>
Date: Mon, 13 Aug 2018 18:33:36 +0800
Subject: [PATCH] shutdown transactionalMessageCheckService

---
 .../java/org/apache/rocketmq/broker/BrokerController.java     | 4 ++++
 1 file changed, 4 insertions(+)

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 f45674d6..78f46a03 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() {
-- 
GitLab