opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-01 15:47:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

InterruptedException should not be ignored (#5515)

Browse Source 
* 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>
This commit is contained in:
asia-zengtao
2022-11-17 15:14:56 +08:00
committed by GitHub
parent b2de9e1cdf
commit 2f7bdda0af
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+2
View File
@@ -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();
}
}