We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9f58198 commit 1a3c922Copy full SHA for 1a3c922
1 file changed
broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -1442,10 +1442,6 @@ protected void shutdownBasicService() {
1442
this.pullRequestHoldService.shutdown();
1443
}
1444
1445
- if (this.popConsumerService != null) {
1446
- this.popConsumerService.shutdown();
1447
- }
1448
-
1449
if (this.popMessageProcessor.getPopLongPollingService() != null) {
1450
this.popMessageProcessor.getPopLongPollingService().shutdown();
1451
@@ -1641,6 +1637,10 @@ protected void shutdownBasicService() {
1641
1637
1642
1638
1643
1639
1640
+ if (this.popConsumerService != null) {
+ this.popConsumerService.shutdown();
+ }
+
1644
if (this.messageStore != null) {
1645
this.messageStore.shutdown();
1646
0 commit comments