Skip to content

Commit c33eb4f

Browse files
committed
increase epsilon to reduce liklihood of failures in ci
and make the bounds inclusive, so the assertion message makes more sense
1 parent c339fab commit c33eb4f

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

test/src/com/rabbitmq/client/test/functional/DeadLetterExchange.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -382,7 +382,7 @@ private void sleep(long millis) {
382382
publication time + TTL + latency */
383383
private void checkPromptArrival(QueueingConsumer c,
384384
int count, long latency) throws Exception {
385-
long epsilon = TTL / 100;
385+
long epsilon = TTL / 50;
386386
for (int i = 0; i < count; i++) {
387387
Delivery d = c.nextDelivery(TTL + TTL + latency + epsilon);
388388
assertNotNull("message #" + i + " did not expire", d);
@@ -391,8 +391,8 @@ private void checkPromptArrival(QueueingConsumer c,
391391
long targetTime = publishTime + TTL + latency;
392392
assertTrue("expiry outside bounds (+/- " + epsilon + "): " +
393393
(now - targetTime),
394-
(now > targetTime - epsilon) &&
395-
(now < targetTime + epsilon));
394+
(now >= targetTime - epsilon) &&
395+
(now <= targetTime + epsilon));
396396
}
397397
}
398398

0 commit comments

Comments
 (0)