From 2f7bdda0af9944b721bf9bd6af6e597edfc803ee Mon Sep 17 00:00:00 2001
From: asia-zengtao <111327440+asia-zengtao@users.noreply.github.com>
Date: Thu, 17 Nov 2022 15:14:56 +0800
Subject: [PATCH] InterruptedException should not be ignored (#5515)

* InterruptedException should not be ignored

InterruptedException should not be ignored
print InterruptedException  message and  Restore interrupted state

* Fix checkstyle issue

Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
---
 .../main/java/org/apache/rocketmq/broker/BrokerController.java  | 2 ++
 1 file changed, 2 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 3f5176e349..e22f1b0a5e 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -1427,6 +1427,8 @@ public class BrokerController {
         try {
             scheduledExecutorService.awaitTermination(5000, TimeUnit.MILLISECONDS);
         } catch (InterruptedException ignore) {
+            BrokerController.LOG.warn("shutdown ScheduledExecutorService was Interrupted!  ", ignore);
+            Thread.currentThread().interrupt();
         }
     }