[rocketmq] branch develop updated: [ISSUE #354]Add thread-sleep for rebalance before producer send in the integration-test (#355)

[vo...@apache.org]

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 840e04c  [ISSUE #354]Add thread-sleep for rebalance before producer send in the integration-test (#355)
840e04c is described below

commit 840e04c7e148674a270481a57304c126e73c1674
Author: what-a-good-jungle <35...@qq.com>
AuthorDate: Fri Jul 13 11:32:13 2018 +0800

    [ISSUE #354]Add thread-sleep for rebalance before producer send in the integration-test (#355)
---
 .../test/client/consumer/balance/NormalMsgDynamicBalanceIT.java        | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java
index ef12621..0467eef 100644
--- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java
@@ -23,6 +23,7 @@ import org.apache.rocketmq.test.client.rmq.RMQNormalConsumer;
 import org.apache.rocketmq.test.client.rmq.RMQNormalProducer;
 import org.apache.rocketmq.test.listener.rmq.concurrent.RMQNormalListener;
 import org.apache.rocketmq.test.util.MQWait;
+import org.apache.rocketmq.test.util.TestUtils;
 import org.apache.rocketmq.test.util.VerifyUtils;
 import org.junit.After;
 import org.junit.Assert;
@@ -54,6 +55,7 @@ public class NormalMsgDynamicBalanceIT extends BaseConf {
         RMQNormalConsumer consumer1 = getConsumer(nsAddr, topic, "*", new RMQNormalListener());
         RMQNormalConsumer consumer2 = getConsumer(nsAddr, consumer1.getConsumerGroup(), topic,
             "*", new RMQNormalListener());
+        TestUtils.waitForSeconds(waitTime);
 
         producer.send(msgSize);
 
@@ -84,6 +86,7 @@ public class NormalMsgDynamicBalanceIT extends BaseConf {
             "*", new RMQNormalListener());
         RMQNormalConsumer consumer3 = getConsumer(nsAddr, consumer1.getConsumerGroup(), topic,
             "*", new RMQNormalListener());
+        TestUtils.waitForSeconds(waitTime);
 
         producer.send(msgSize);