You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2022/07/18 01:20:09 UTC
[rocketmq] branch develop updated: Try to make CI test more stable (#4616)
This is an automated email from the ASF dual-hosted git repository.
dinglei 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 3ee603a49 Try to make CI test more stable (#4616)
3ee603a49 is described below
commit 3ee603a49b04c0b602ff8eb45b3ef4330293fba8
Author: rongtong <ji...@163.com>
AuthorDate: Mon Jul 18 09:19:43 2022 +0800
Try to make CI test more stable (#4616)
---
.../org/apache/rocketmq/test/statictopic/StaticTopicIT.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/test/src/test/java/org/apache/rocketmq/test/statictopic/StaticTopicIT.java b/test/src/test/java/org/apache/rocketmq/test/statictopic/StaticTopicIT.java
index b198c7a7a..29b92d5f4 100644
--- a/test/src/test/java/org/apache/rocketmq/test/statictopic/StaticTopicIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/statictopic/StaticTopicIT.java
@@ -108,7 +108,7 @@ public class StaticTopicIT extends BaseConf {
RMQNormalProducer producer = getProducer(nsAddr, topic);
RMQNormalConsumer consumer = getConsumer(nsAddr, topic, "*", new RMQNormalListener());
int queueNum = 10;
- int msgEachQueue = 100;
+ int msgEachQueue = 10;
{
Set<String> brokers = ImmutableSet.of(broker1Name);
MQAdminTestUtils.createStaticTopicWithCommand(topic, queueNum, brokers, null, nsAddr);
@@ -207,7 +207,7 @@ public class StaticTopicIT extends BaseConf {
}
private void consumeMessagesAndCheck(RMQNormalProducer producer, RMQNormalConsumer consumer, String topic, int queueNum, int msgEachQueue, int startGen, int genNum) {
- consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), 30000);
+ consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), 60000);
// System.out.println("produce:" + producer.getAllMsgBody().size());
// System.out.println("consume:" + consumer.getListener().getAllMsgBody().size());
@@ -243,7 +243,7 @@ public class StaticTopicIT extends BaseConf {
RMQNormalConsumer consumer = getConsumer(nsAddr, topic, "*", new RMQNormalListener());
int queueNum = 10;
- int msgEachQueue = 100;
+ int msgEachQueue = 10;
//create static topic
Map<String, TopicConfigAndQueueMapping> localBrokerConfigMap = MQAdminTestUtils.createStaticTopic(topic, queueNum, getBrokers(), defaultMQAdminExt);
//check the static topic config
@@ -275,7 +275,7 @@ public class StaticTopicIT extends BaseConf {
RMQNormalConsumer consumer = getConsumer(nsAddr, topic, "*", new RMQNormalListener());
int queueNum = 1;
- int msgEachQueue = 100;
+ int msgEachQueue = 10;
//create send consume
{
Set<String> targetBrokers = ImmutableSet.of(broker1Name);
@@ -346,7 +346,7 @@ public class StaticTopicIT extends BaseConf {
long start = System.currentTimeMillis();
int queueNum = 10;
- int msgEachQueue = 100;
+ int msgEachQueue = 10;
//create static topic
{
Set<String> targetBrokers = ImmutableSet.of(broker1Name);