(rocketmq) branch develop updated: Defer the shutdown behavior of popConsumerService to prevent JVM crash (#9889)

[ltamber]

This is an automated email from the ASF dual-hosted git repository.

ltamber pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 1a3c922fdf Defer the shutdown behavior of popConsumerService to 
prevent JVM crash (#9889)
1a3c922fdf is described below

commit 1a3c922fdf2eb263bc2c8e4719cac6928dd0f519
Author: rongtong <jinrongton...@mails.ucas.ac.cn>
AuthorDate: Wed Dec 3 14:15:22 2025 +0800

    Defer the shutdown behavior of popConsumerService to prevent JVM crash 
(#9889)
    
    Change-Id: Iaa23996d94f81ed3250b8d528338e8502a35cada
    
    Co-authored-by: RongtongJin <u...@example.com>
---
 .../main/java/org/apache/rocketmq/broker/BrokerController.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

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 3fb9149056..de1cbfc823 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -1442,10 +1442,6 @@ public class BrokerController {
             this.pullRequestHoldService.shutdown();
         }
 
-        if (this.popConsumerService != null) {
-            this.popConsumerService.shutdown();
-        }
-
         if (this.popMessageProcessor.getPopLongPollingService() != null) {
             this.popMessageProcessor.getPopLongPollingService().shutdown();
         }
@@ -1641,6 +1637,10 @@ public class BrokerController {
             }
         }
 
+        if (this.popConsumerService != null) {
+            this.popConsumerService.shutdown();
+        }
+
         if (this.messageStore != null) {
             this.messageStore.shutdown();
         }