[ISSUE #7343] Rollback modifications to registerProcessor

guyinyou · guyinyou · web-flow · commit 57f04c95d3a2 · 2023-09-11T18:23:25.000+08:00
Co-authored-by: guyinyou &lt;guyinyou.gyy@alibaba-inc.com&gt;
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() {

Original file line number	Diff line number	Diff line change
`@@ -827,6 +827,8 @@ public boolean recoverAndInitService() throws CloneNotSupportedException {`
`827`	`827`
`828`	`828`	`initializeResources();`
`829`	`829`
	`830`	`+ registerProcessor();`
	`831`	`+`
`830`	`832`	`initializeScheduledTasks();`
`831`	`833`
`832`	`834`	`initialTransaction();`
`@@ -1687,8 +1689,6 @@ public void run() {`
`1687`	`1689`	`}`
`1688`	`1690`	`}`
`1689`	`1691`	`}, 10, 5, TimeUnit.SECONDS);`
`1690`		`-`
`1691`		`- registerProcessor();`
`1692`	`1692`	`}`
`1693`	`1693`
`1694`	`1694`	`protected void scheduleSendHeartbeat() {`