Skip to content

R
Rocketmq

Kwan的解忧杂货铺@新空间代码工作室 / Rocketmq
与 Fork 源项目一致

Fork自 Apache RocketMQ / Rocketmq

通知 1
Star 0
Fork 0
R
Rocketmq
提交 840e04c7 编写于 作者: W what-a-good-jungle 提交者： von gosling
浏览文件
操作

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

上级 94f3b5a4
隐藏空白更改
内联 并排
Showing with 3 addition and 0 deletion
test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java
浏览文件 @ 840e04c7
...@@ -23,6 +23,7 @@ import org.apache.rocketmq.test.client.rmq.RMQNormalConsumer; ...@@ -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.client.rmq.RMQNormalProducer;
import org.apache.rocketmq.test.listener.rmq.concurrent.RMQNormalListener; import org.apache.rocketmq.test.listener.rmq.concurrent.RMQNormalListener;
import org.apache.rocketmq.test.util.MQWait; import org.apache.rocketmq.test.util.MQWait;
import org.apache.rocketmq.test.util.TestUtils;
import org.apache.rocketmq.test.util.VerifyUtils; import org.apache.rocketmq.test.util.VerifyUtils;
import org.junit.After; import org.junit.After;
import org.junit.Assert; import org.junit.Assert;
...@@ -54,6 +55,7 @@ public class NormalMsgDynamicBalanceIT extends BaseConf { ...@@ -54,6 +55,7 @@ public class NormalMsgDynamicBalanceIT extends BaseConf {
RMQNormalConsumer consumer1 = getConsumer(nsAddr, topic, "*", new RMQNormalListener()); RMQNormalConsumer consumer1 = getConsumer(nsAddr, topic, "*", new RMQNormalListener());
RMQNormalConsumer consumer2 = getConsumer(nsAddr, consumer1.getConsumerGroup(), topic, RMQNormalConsumer consumer2 = getConsumer(nsAddr, consumer1.getConsumerGroup(), topic,
"*", new RMQNormalListener()); "*", new RMQNormalListener());
TestUtils.waitForSeconds(waitTime);
producer.send(msgSize); producer.send(msgSize);
...@@ -84,6 +86,7 @@ public class NormalMsgDynamicBalanceIT extends BaseConf { ...@@ -84,6 +86,7 @@ public class NormalMsgDynamicBalanceIT extends BaseConf {
"*", new RMQNormalListener()); "*", new RMQNormalListener());
RMQNormalConsumer consumer3 = getConsumer(nsAddr, consumer1.getConsumerGroup(), topic, RMQNormalConsumer consumer3 = getConsumer(nsAddr, consumer1.getConsumerGroup(), topic,
"*", new RMQNormalListener()); "*", new RMQNormalListener());
TestUtils.waitForSeconds(waitTime);
producer.send(msgSize); producer.send(msgSize);
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或