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 9246d6f208f7b110d7d608c41c31a536c361d6c6..b6613853a9a4964a953842147bfccc369e3c2a5a 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");