Skip to content

Commit 7715f41

Browse files
committed
Improve resilience of some tests
1 parent f0173cb commit 7715f41

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -583,7 +583,7 @@ private void sleep(long millis) {
583583
publication time + TTL + latency */
584584
private void checkPromptArrival(QueueingConsumer c,
585585
int count, long latency) throws Exception {
586-
long epsilon = TTL / 25;
586+
long epsilon = TTL / 20;
587587
for (int i = 0; i < count; i++) {
588588
Delivery d = c.nextDelivery(TTL + TTL + latency + epsilon);
589589
assertNotNull("message #" + i + " did not expire", d);

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,7 @@ protected void releaseResources() throws IOException {
156156
closeChannel();
157157
openChannel();
158158

159-
Thread.sleep(150);
159+
Thread.sleep(200);
160160
expectBodyAndRemainingMessages(MSG[1], 1);
161161
expectBodyAndRemainingMessages(MSG[2], 0);
162162
}

0 commit comments

Comments
 (0)