You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vo...@apache.org on 2018/07/14 02:57:31 UTC
[rocketmq] branch develop updated: [ROCKETMQ-296] fix
DefaultMessageStoreTest bug: wait more time for consume queue build (#165)
This is an automated email from the ASF dual-hosted git repository.
vongosling 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 6eed5f1 [ROCKETMQ-296] fix DefaultMessageStoreTest bug: wait more time for consume queue build (#165)
6eed5f1 is described below
commit 6eed5f1cdc8f105c8471c55804a6d27f97482a45
Author: Wenwei Hu <we...@163.com>
AuthorDate: Sat Jul 14 10:57:29 2018 +0800
[ROCKETMQ-296] fix DefaultMessageStoreTest bug: wait more time for consume queue build (#165)
---
.../java/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 a400ed5..20f94f0 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);