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 e43bb4bc3d..db7d367e02 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); }