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

Increased timeout for test method.

Browse Source
This commit is contained in:
Mark Fisher
2008-06-30 23:05:58 +00:00
parent 5235537c80
commit 504b101213
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
org.springframework.integration/src/test/java/org/springframework/integration/router/AggregatingMessageHandlerTests.java
View File

@@ -90,7 +90,7 @@ public class AggregatingMessageHandlerTests {
@Test
public void testShouldSendPartialResultOnTimeoutTrue() throws InterruptedException {
AggregatingMessageHandler aggregator = new AggregatingMessageHandler(new TestAggregator());
aggregator.setTimeout(50);
aggregator.setTimeout(500);
aggregator.setReaperInterval(10);
aggregator.setSendPartialResultOnTimeout(true);
QueueChannel replyChannel = new QueueChannel();
@@ -103,7 +103,7 @@ public class AggregatingMessageHandlerTests {
executor.execute(task2);
latch.await(3000, TimeUnit.MILLISECONDS);
assertEquals("handlers should have been invoked within time limit", 0, latch.getCount());
Message<?> reply = replyChannel.receive(1000);
Message<?> reply = replyChannel.receive(3000);
assertNotNull("a reply message should have been received", reply);
assertEquals("123456", reply.getPayload());
assertNull(task1.getException());