Fix error tests, producer should wait a while for consumer to be ready
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/3d1ec328 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/3d1ec328 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/3d1ec328 Branch: refs/heads/release-4.1.0-incubating Commit: 3d1ec3289d96bc8464e507b6a446506ca26cf7e0 Parents: 0fe9471 Author: dongeforever <zhendongli...@yeah.net> Authored: Tue Jun 6 10:44:55 2017 +0800 Committer: dongeforever <zhendongli...@yeah.net> Committed: Tue Jun 6 10:44:55 2017 +0800 ---------------------------------------------------------------------- .../consumer/broadcast/normal/BroadCastNormalMsgNotRecvIT.java | 4 ++-- .../producer/async/AsyncSendWithMessageQueueSelectorIT.java | 1 + 2 files changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3d1ec328/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgNotRecvIT.java ---------------------------------------------------------------------- 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 65762fa..32b13fd 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()); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3d1ec328/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueSelectorIT.java ---------------------------------------------------------------------- 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 843441d..82012ea 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