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 2b80a54 commit e93b11aCopy full SHA for e93b11a
src/test/java/com/rabbitmq/client/test/functional/DeadLetterExchange.java
@@ -564,7 +564,7 @@ private void sleep(long millis) {
564
publication time + TTL + latency */
565
private void checkPromptArrival(QueueMessageConsumer c,
566
int count, long latency) throws Exception {
567
- long epsilon = TTL / 10;
+ long epsilon = TTL / 5;
568
for (int i = 0; i < count; i++) {
569
byte[] body = c.nextDelivery(TTL + TTL + latency + epsilon);
570
assertNotNull("message #" + i + " did not expire", body);
0 commit comments