Increased time limit.

This commit is contained in:
Mark Fisher
2008-01-03 16:13:01 +00:00
parent 27948795f0
commit 5d9602d497

View File

@@ -65,7 +65,7 @@ public class FixedDelayConsumerTests {
for (int i = 0; i < messagesToSend; i++) {
channel.send(new GenericMessage<String>(1, "test " + (i+1)));
}
latch.await(500, TimeUnit.MILLISECONDS);
latch.await(1000, TimeUnit.MILLISECONDS);
assertEquals(messagesToSend, counter.get());
}