You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ni...@apache.org on 2016/12/26 03:49:47 UTC
incubator-rocketmq git commit: [ROCKETMQ-3] Remove try...catch,
using assertNull etc
Repository: incubator-rocketmq
Updated Branches:
refs/heads/master 03880d77a -> 360341e56
[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/360341e5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/360341e5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/360341e5
Branch: refs/heads/master
Commit: 360341e56da3dfed2c5175e99a599aff9e772a3e
Parents: 03880d7
Author: zhendongliu.lzd <zh...@alibaba-inc.com>
Authored: Mon Dec 26 10:31:45 2016 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Mon Dec 26 11:46:09 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/360341e5/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");