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