[ISSUE #2645] Fix unit case NPE in DefaultMessageStoreShutDownTest#testDispatchBehindWhenShutdown

606de993 · 赵延 · GitHub · 0d8a184a · 606de993
隐藏空白更改
内联并排

Showing with 4 addition and 3 deletion

store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreShutDownTest.java ...pache/rocketmq/store/DefaultMessageStoreShutDownTest.java +4 -3

未找到文件。
--- a/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreShutDownTest.java
+++ b/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreShutDownTest.java
@@ -40,10 +40,11 @@ public class DefaultMessageStoreShutDownTest {

    @Before
    public void init() throws Exception {
-        messageStore = spy(buildMessageStore());
-        boolean load = messageStore.load();
+        DefaultMessageStore store = buildMessageStore();
+        boolean load = store.load();
        assertTrue(load);
-        messageStore.start();
+        store.start();
+        messageStore = spy(store);
        when(messageStore.dispatchBehindBytes()).thenReturn(100L);
    }