Increased the timeout

This commit is contained in:
Marius Bogoevici
2008-05-24 16:20:34 +00:00
parent 04ae83e562
commit 2498df7f50

View File

@@ -103,7 +103,7 @@ public class AggregatingMessageHandlerTests {
executor.execute(task2);
latch.await(2000, TimeUnit.MILLISECONDS);
assertEquals("handlers should have been invoked within time limit", 0, latch.getCount());
Message<?> reply = replyChannel.receive(500);
Message<?> reply = replyChannel.receive(1000);
assertNotNull("a reply message should have been received", reply);
assertEquals("123456", reply.getPayload());
assertNull(task1.getException());