From 0c5e53db6f4d0ed9f25747379a8b679e2da5392d Mon Sep 17 00:00:00 2001 From: dongeforever Date: Tue, 6 Jun 2017 10:44:55 +0800 Subject: [PATCH] Fix error tests, producer should wait a while for consumer to be ready --- .../broadcast/normal/BroadCastNormalMsgNotRecvIT.java | 4 ++-- .../producer/async/AsyncSendWithMessageQueueSelectorIT.java | 1 + 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgNotRecvIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgNotRecvIT.java index 65762fab..32b13fd7 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgNotRecvIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgNotRecvIT.java @@ -50,13 +50,13 @@ public class BroadCastNormalMsgNotRecvIT extends BaseBroadCastIT { } @Test - public void testNotConsumeAfterConsume() { + public void testNotConsumeAfterConsume() throws Exception { int msgSize = 16; String group = initConsumerGroup(); RMQBroadCastConsumer consumer1 = getBroadCastConsumer(nsAddr, group, topic, "*", new RMQNormalListner(group + "_1")); - + Thread.sleep(3000); producer.send(msgSize); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueSelectorIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueSelectorIT.java index 843441d3..82012eab 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueSelectorIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueSelectorIT.java @@ -80,6 +80,7 @@ public class AsyncSendWithMessageQueueSelectorIT extends BaseConf { producer.clearMsg(); consumer.clearMsg(); + producer.getSuccessSendResult().clear(); producer.asyncSend(msgSize, new MessageQueueSelector() { @Override -- GitLab