diff --git a/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreTest.java b/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreTest.java index a400ed5a5a7e818527645d6b409fee27a326320b..20f94f09a0593c0f319b1af06763af22e34bf12c 100644 --- a/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreTest.java +++ b/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreTest.java @@ -98,6 +98,7 @@ public class DefaultMessageStoreTest { messageStoreConfig.setMaxHashSlotNum(10000); messageStoreConfig.setMaxIndexNum(100 * 100); messageStoreConfig.setFlushDiskType(FlushDiskType.SYNC_FLUSH); + messageStoreConfig.setFlushIntervalConsumeQueue(1); return new DefaultMessageStore(messageStoreConfig, new BrokerStatsManager("simpleTest"), new MyMessageArrivingListener(), new BrokerConfig()); } @@ -156,8 +157,9 @@ public class DefaultMessageStoreTest { messageExtBrokerInner.setQueueId(0); messageStore.putMessage(messageExtBrokerInner); } - //wait for consume queue build - Thread.sleep(10); + // wait for consume queue build + // the sleep time should be great than consume queue flush interval + Thread.sleep(100); String group = "simple"; GetMessageResult getMessageResult32 = messageStore.getMessage(group, topic, 0, 0, 32, null); assertThat(getMessageResult32.getMessageBufferList().size()).isEqualTo(32);