We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a22b758 commit e640ec5Copy full SHA for e640ec5
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