This is an automated email from the ASF dual-hosted git repository.
jinrongtong 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 57f04c95d3 [ISSUE #7343] Rollback modifications to registerProcessor
57f04c95d3 is described below
commit 57f04c95d3a2ba6b91583058a6e4eda209f72d6e
Author: guyinyou <[email protected]>
AuthorDate: Mon Sep 11 18:23:25 2023 +0800
[ISSUE #7343] Rollback modifications to registerProcessor
Co-authored-by: guyinyou <[email protected]>
---
broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java | 4 ++--
1 file changed, 2 insertions(+), 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
index 9e49f636d2..13a3feb4e6 100644
--- 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 class BrokerController {
initializeResources();
+ registerProcessor();
+
initializeScheduledTasks();
initialTransaction();
@@ -1687,8 +1689,6 @@ public class BrokerController {
}
}
}, 10, 5, TimeUnit.SECONDS);
-
- registerProcessor();
}
protected void scheduleSendHeartbeat() {
