You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by do...@apache.org on 2017/06/06 03:38:26 UTC
[06/51] [abbrv] incubator-rocketmq git commit: Trivial simplification
of broker initialization by removing unnecessary assignment.
Trivial simplification of broker initialization by removing unnecessary assignment.
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/aa694f25
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/aa694f25
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/aa694f25
Branch: refs/heads/master
Commit: aa694f25111b91ba14857be9aafe04dd70b71b17
Parents: 82fb4e0
Author: shtykh_roman <rs...@yahoo.com>
Authored: Tue Mar 28 10:22:53 2017 +0900
Committer: dongeforever <zh...@yeah.net>
Committed: Tue Jun 6 11:37:29 2017 +0800
----------------------------------------------------------------------
.../main/java/org/apache/rocketmq/broker/BrokerController.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/aa694f25/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
----------------------------------------------------------------------
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 7e9e7ac..6acd40c 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -188,9 +188,7 @@ public class BrokerController {
}
public boolean initialize() throws CloneNotSupportedException {
- boolean result = true;
-
- result = result && this.topicConfigManager.load();
+ boolean result = this.topicConfigManager.load();
result = result && this.consumerOffsetManager.load();
result = result && this.subscriptionGroupManager.load();