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

Increased timeouts.

Browse Source
This commit is contained in:
Marius Bogoevici
2008-06-20 04:39:29 +00:00
parent 83abe6a2f3
commit deff988c74
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
org.springframework.integration/src/test/java/org/springframework/integration/bus/MessageBusTests.java
View File

@@ -175,7 +175,7 @@ public class MessageBusTests {
SourceEndpoint sourceEndpoint = new SourceEndpoint(new FailingSource(latch), new QueueChannel(), new PollingSchedule(1000));
bus.registerEndpoint("testEndpoint", sourceEndpoint);
bus.start();
latch.await(1000, TimeUnit.MILLISECONDS);
latch.await(2000, TimeUnit.MILLISECONDS);
Message<?> message = bus.getErrorChannel().receive(100);
assertNotNull("message should not be null", message);
assertTrue(message instanceof ErrorMessage);

2
org.springframework.integration/src/test/java/org/springframework/integration/gateway/RequestReplyTemplateTests.java
View File

@@ -77,7 +77,7 @@ public class RequestReplyTemplateTests {
template.request(new StringMessage("test1"), replyHandler);
template.request(new StringMessage("test2"), replyHandler);
template.request(new StringMessage("test3"), replyHandler);
latch.await(1000, TimeUnit.MILLISECONDS);
latch.await(2000, TimeUnit.MILLISECONDS);
assertEquals(0, latch.getCount());
assertTrue(replies.contains("TEST1"));
assertTrue(replies.contains("TEST2"));