You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ni...@apache.org on 2022/05/16 08:56:55 UTC
[pulsar] 02/02: [improve] [test] Improve timeout problem at SimpleProducerConsumerTest#testRedeliveryFailOverConsumer. (#15404)
This is an automated email from the ASF dual-hosted git repository.
nicoloboschi pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 4c8baedfda09deacf5f7a611251f4e1597d745fb
Author: Yan Zhao <ho...@apache.org>
AuthorDate: Wed May 4 10:25:47 2022 +0800
[improve] [test] Improve timeout problem at SimpleProducerConsumerTest#testRedeliveryFailOverConsumer. (#15404)
(cherry picked from commit 7d06b5f00d8c981c4b7d18f3833018cc03893e02)
---
.../apache/pulsar/client/api/SimpleProducerConsumerTest.java | 11 ++---------
1 file changed, 2 insertions(+), 9 deletions(-)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
index 95324f856da..ac0186c3c5a 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
@@ -2424,9 +2424,9 @@ public class SimpleProducerConsumerTest extends ProducerConsumerBase {
Producer<byte[]> producer = pulsarClient.newProducer().topic("persistent://my-property/my-ns/unacked-topic")
.create();
- // (1) First round to produce-consume messages
+ // (1) send all message at once
int consumeMsgInParts = 4;
- for (int i = 0; i < receiverQueueSize; i++) {
+ for (int i = 0; i < receiverQueueSize * 2; i++) {
String message = "my-message-" + i;
producer.send(message.getBytes());
}
@@ -2464,13 +2464,6 @@ public class SimpleProducerConsumerTest extends ProducerConsumerBase {
consumer.redeliverUnacknowledgedMessages();
Thread.sleep(1000L);
- // (2) Second round to produce-consume messages
- for (int i = 0; i < receiverQueueSize; i++) {
- String message = "my-message-" + i;
- producer.send(message.getBytes());
- }
- producer.flush();
-
int remainingMsgs = (2 * receiverQueueSize) - (2 * consumeMsgInParts);
messages1.clear();
for (int i = 0; i < remainingMsgs; i++) {