You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2019/02/21 02:42:59 UTC
[rocketmq] branch develop updated: [RIP-10] Optimize test batch
send message use cases(#831)
This is an automated email from the ASF dual-hosted git repository.
dinglei 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 13b5dd1 [RIP-10] Optimize test batch send message use cases(#831)
13b5dd1 is described below
commit 13b5dd11603c4c01f793720ac608dcca3b57a3e8
Author: zhoubo <zh...@outlook.com>
AuthorDate: Thu Feb 21 10:42:53 2019 +0800
[RIP-10] Optimize test batch send message use cases(#831)
[RIP-10] Optimize test batch send message use cases
---
.../src/test/java/org/apache/rocketmq/store/BatchPutMessageTest.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/store/src/test/java/org/apache/rocketmq/store/BatchPutMessageTest.java b/store/src/test/java/org/apache/rocketmq/store/BatchPutMessageTest.java
index 8de0a2c..3817849 100644
--- a/store/src/test/java/org/apache/rocketmq/store/BatchPutMessageTest.java
+++ b/store/src/test/java/org/apache/rocketmq/store/BatchPutMessageTest.java
@@ -78,7 +78,7 @@ public class BatchPutMessageTest {
}
@Test
- public void testPutMessages() {
+ public void testPutMessages() throws Exception {
List<Message> messages = new ArrayList<>();
String topic = "batch-write-topic";
int queue = 0;
@@ -111,6 +111,8 @@ public class BatchPutMessageTest {
PutMessageResult putMessageResult = messageStore.putMessages(messageExtBatch);
assertThat(putMessageResult.isOk()).isTrue();
+
+ Thread.sleep(3 * 1000);
for (long i = 0; i < 10; i++) {
MessageExt messageExt = messageStore.lookMessageByOffset(msgLengthArr[(int) i]);