提交 1970813c 编写于 作者: L Li Zhanhui

Shutdown all started executors of broker

上级 8422e74f
......@@ -682,6 +682,22 @@ public class BrokerController {
if (this.consumerFilterManager != null) {
this.consumerFilterManager.persist();
}
if (this.clientManageExecutor != null) {
this.clientManageExecutor.shutdown();
}
if (this.queryMessageExecutor != null) {
this.queryMessageExecutor.shutdown();
}
if (this.consumerManageExecutor != null) {
this.consumerManageExecutor.shutdown();
}
if (this.fileWatchService != null) {
this.fileWatchService.shutdown();
}
}
private void unregisterBrokerAll() {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册