From 13b5dd11603c4c01f793720ac608dcca3b57a3e8 Mon Sep 17 00:00:00 2001
From: zhoubo <zhouboatzzu@outlook.com>
Date: Thu, 21 Feb 2019 10:42:53 +0800
Subject: [PATCH] [RIP-10] Optimize test batch send message use cases(#831)

[RIP-10] Optimize test batch send message use cases
---
 .../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 8de0a2cc..38178490 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]);
-- 
GitLab