[rocketmq] branch develop updated: [ISSUE #2645] Fix unit case NPE in DefaultMessageStoreShutDownTest#testDispatchBehindWhenShutdown

[ji...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 606de99  [ISSUE #2645] Fix unit case NPE in DefaultMessageStoreShutDownTest#testDispatchBehindWhenShutdown
606de99 is described below

commit 606de993d3da0e6cec3d5e6f1c2a9126abec054b
Author: 赵延 <10...@qq.com>
AuthorDate: Mon Feb 15 21:01:21 2021 +0800

    [ISSUE #2645] Fix unit case NPE in DefaultMessageStoreShutDownTest#testDispatchBehindWhenShutdown
---
 .../org/apache/rocketmq/store/DefaultMessageStoreShutDownTest.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreShutDownTest.java b/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreShutDownTest.java
index e43bb4b..db7d367 100644
--- 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);
     }