Zintoki commented on PR #51:
URL: https://github.com/apache/rocketmq-e2e/pull/51#issuecomment-1767988830
ok
---Original---
From: ***@***.***>
Date: Tue, Oct 17, 2023 15:40 PM
To: ***@***.***>;
Cc: "XiaoWei ***@***.******@***.***>;
Subject: Re: [apache/rocketmq-e2e] Added the java4.x client cluster
filterpull test content (PR #51)
@cryptoya commented on this pull request.
In java/e2e-v4/src/test/java/org/apache/rocketmq/cluster/ClusterTest.java:
> + if (pushConsumer02 != null) { +
pushConsumer02.shutdown(); + } + if (pushConsumer03 != null) { +
pushConsumer03.shutdown(); + } + if (pullConsumer !=
null) { + pullConsumer.shutdown(); + } + if (producer
!= null) { + producer.shutdown(); + } + } + + @Test +
@DisplayName("Send 100 normal messages synchronously, start three consumers on
different GroupId, and expect each client to consume up to 100 messages")
增加一下MessageModel为广播模式的场景
—
Reply to this email directly, view it on GitHub, or unsubscribe.
You are receiving this because you authored the thread.Message ID:
***@***.***>
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
