We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 08270dd commit 9079262Copy full SHA for 9079262
1 file changed
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/DelayedDeliveryTest.java
@@ -483,10 +483,10 @@ public void testEnableTopicDelayedDelivery() throws Exception {
483
break;
484
}
485
486
- producer.newMessage().value("long-tick-msg").deliverAfter(2, TimeUnit.SECONDS).send();
+ producer.newMessage().value("long-tick-msg").deliverAfter(3, TimeUnit.SECONDS).send();
487
msg = consumer.receive(1, TimeUnit.SECONDS);
488
assertNull(msg);
489
- msg = consumer.receive(3, TimeUnit.SECONDS);
+ msg = consumer.receive(4, TimeUnit.SECONDS);
490
assertNotNull(msg);
491
492
0 commit comments