You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by lo...@apache.org on 2016/12/27 06:58:27 UTC
[4/4] incubator-rocketmq git commit: [ROCKETMQ-3] Remove try...catch,
using assertNull etc
[ROCKETMQ-3] Remove try...catch, using assertNull etc
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/626990cf
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/626990cf
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/626990cf
Branch: refs/heads/master
Commit: 626990cf352e4832b2dfc4d96e710d43723849a2
Parents: 03880d7
Author: dongeforever <zh...@yeah.net>
Authored: Mon Dec 26 10:31:45 2016 +0800
Committer: lollipop <lo...@apache.org>
Committed: Tue Dec 27 14:53:17 2016 +0800
----------------------------------------------------------------------
.../java/com/alibaba/rocketmq/broker/BrokerControllerTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/626990cf/rocketmq-broker/src/test/java/com/alibaba/rocketmq/broker/BrokerControllerTest.java
----------------------------------------------------------------------
diff --git a/rocketmq-broker/src/test/java/com/alibaba/rocketmq/broker/BrokerControllerTest.java b/rocketmq-broker/src/test/java/com/alibaba/rocketmq/broker/BrokerControllerTest.java
index 9246d6f..b661385 100644
--- a/rocketmq-broker/src/test/java/com/alibaba/rocketmq/broker/BrokerControllerTest.java
+++ b/rocketmq-broker/src/test/java/com/alibaba/rocketmq/broker/BrokerControllerTest.java
@@ -21,6 +21,7 @@ import com.alibaba.rocketmq.common.BrokerConfig;
import com.alibaba.rocketmq.remoting.netty.NettyClientConfig;
import com.alibaba.rocketmq.remoting.netty.NettyServerConfig;
import com.alibaba.rocketmq.store.config.MessageStoreConfig;
+import org.junit.Assert;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -48,8 +49,8 @@ public class BrokerControllerTest {
new NettyClientConfig(), //
new MessageStoreConfig());
boolean initResult = brokerController.initialize();
+ Assert.assertTrue(initResult);
logger.info("Broker is initialized " + initResult);
-
brokerController.start();
logger.info("Broker is started");