We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b47f17c commit 7343fd2Copy full SHA for 7343fd2
src/test/java/com/rabbitmq/client/test/functional/DeadLetterExchange.java
@@ -573,7 +573,7 @@ private void sleep(long millis) {
573
publication time + TTL + latency */
574
private void checkPromptArrival(AccumulatingMessageConsumer c,
575
int count, long latency) throws Exception {
576
- long epsilon = TTL / 10;
+ long epsilon = TTL / 5;
577
for (int i = 0; i < count; i++) {
578
byte[] body = c.nextDelivery(TTL + TTL + latency + epsilon);
579
assertNotNull("message #" + i + " did not expire", body);
0 commit comments