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 <[email protected]> Authored: Mon Dec 26 10:31:45 2016 +0800 Committer: Willem Jiang <[email protected]> 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");
