Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adjusted timing for test.

Browse Source
This commit is contained in:
Mark Fisher
2008-02-28 00:23:01 +00:00
parent 8a6c4babee
commit ef1a0b2af5
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-integration-core/src/test/java/org/springframework/integration/router/AggregatingMessageHandlerTests.java
View File

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