From 6eed5f1cdc8f105c8471c55804a6d27f97482a45 Mon Sep 17 00:00:00 2001 From: Wenwei Hu Date: Sat, 14 Jul 2018 10:57:29 +0800 Subject: [PATCH] [ROCKETMQ-296] fix DefaultMessageStoreTest bug: wait more time for consume queue build (#165) --- .../org/apache/rocketmq/store/DefaultMessageStoreTest.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) 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 a400ed5a..20f94f09 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); -- GitLab