[ISSUE #7343] Rollback modifications to registerProcessor

Co-authored-by: guyinyou <[email protected]>
apache · Sep 11, 2023 · 57f04c9 · 57f04c9
1 parent a9e3532
commit 57f04c9
Showing 1 changed file with 2 additions and 2 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
@@ -827,6 +827,8 @@ public boolean recoverAndInitService() throws CloneNotSupportedException {
 
             initializeResources();
 
+            registerProcessor();
+
             initializeScheduledTasks();
 
             initialTransaction();
@@ -1687,8 +1689,6 @@ public void run() {
                 }
             }
         }, 10, 5, TimeUnit.SECONDS);
-
-        registerProcessor();
     }
 
     protected void scheduleSendHeartbeat() {