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

increased timeout on failing tests

Browse Source
This commit is contained in:
Jonas Partner
2008-06-20 15:16:19 +00:00
parent 77faf4fe5e
commit f3d2c23069
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
org.springframework.integration/src/test/java/org/springframework/integration/message/RetrievalBlockingMessageStoreTests.java
View File

@@ -32,7 +32,7 @@ public class RetrievalBlockingMessageStoreTests {
@Test
public void testGetWithElapsedTimeout() {
final RetrievalBlockingMessageStore store = new RetrievalBlockingMessageStore(10);
publishWithDelay(store, "foo", "bar", 1000);
publishWithDelay(store, "foo", "bar", 2000);
Message<?> message = store.get("foo", 5);
assertNull(message);
}
@@ -41,7 +41,7 @@ public class RetrievalBlockingMessageStoreTests {
public void testWrappedTargetGetWithElapsedTimeout() {
MessageStore target = new SimpleMessageStore(10);
final RetrievalBlockingMessageStore store = new RetrievalBlockingMessageStore(target);
publishWithDelay(store, "foo", "bar", 1000);
publishWithDelay(store, "foo", "bar", 2000);
Message<?> message = store.get("foo", 5);
assertNull(message);
}

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

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