We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9609722 commit 6d4fb83Copy full SHA for 6d4fb83
1 file changed
broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -1539,6 +1539,10 @@ protected void shutdownBasicService() {
1539
if (this.transactionalMessageCheckService != null) {
1540
this.transactionalMessageCheckService.shutdown(false);
1541
}
1542
+
1543
+ if (this.loadBalanceExecutor != null) {
1544
+ this.loadBalanceExecutor.shutdown();
1545
+ }
1546
1547
if (this.endTransactionExecutor != null) {
1548
this.endTransactionExecutor.shutdown();
0 commit comments