From 901e06afa259ed16be53b1d812c38c48f0f347dc Mon Sep 17 00:00:00 2001 From: dongeforever Date: Tue, 21 Aug 2018 11:40:08 +0800 Subject: [PATCH] Fix } --- .../main/java/org/apache/rocketmq/broker/BrokerController.java | 1 + 1 file changed, 1 insertion(+) 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 4ac96c53..e7ef46d0 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(); -- GitLab