Skip to content

Commit f5e04af

Browse files
author
Simon MacMullen
committed
Roll back those changes, those timeouts depend on timing out. They should alomost certnily be replaced by assertDelivered(q, 0) but I'll leave that to Michael.
1 parent a535c0b commit f5e04af

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -204,7 +204,7 @@ public void testThatDeletedQueueBindingsDontReappearOnRecovery() throws IOExcept
204204
closeAndWaitForRecovery(connection);
205205
expectChannelRecovery(channel);
206206
channel.basicPublish(x2, "", null, "msg".getBytes());
207-
assertFalse(wait(latch));
207+
assertFalse(latch.await(5, TimeUnit.SECONDS));
208208
} finally {
209209
channel.exchangeDelete(x2);
210210
}
@@ -226,7 +226,7 @@ public void testThatDeletedExchangeBindingsDontReappearOnRecovery() throws IOExc
226226
closeAndWaitForRecovery(connection);
227227
expectChannelRecovery(channel);
228228
channel.basicPublish(x2, "", null, "msg".getBytes());
229-
assertFalse(wait(latch));
229+
assertFalse(latch.await(5, TimeUnit.SECONDS));
230230
} finally {
231231
channel.exchangeDelete(x2);
232232
}

0 commit comments

Comments
 (0)