From f3d2c23069f7872cde9b2f8685cc04a4705f903d Mon Sep 17 00:00:00 2001 From: Jonas Partner Date: Fri, 20 Jun 2008 15:16:19 +0000 Subject: [PATCH] increased timeout on failing tests --- .../message/RetrievalBlockingMessageStoreTests.java | 4 ++-- .../integration/router/AggregatingMessageHandlerTests.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/message/RetrievalBlockingMessageStoreTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/message/RetrievalBlockingMessageStoreTests.java index 9fd5528f6b..ac26e11051 100644 --- a/org.springframework.integration/src/test/java/org/springframework/integration/message/RetrievalBlockingMessageStoreTests.java +++ b/org.springframework.integration/src/test/java/org/springframework/integration/message/RetrievalBlockingMessageStoreTests.java @@ -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); } diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/router/AggregatingMessageHandlerTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/router/AggregatingMessageHandlerTests.java index b372809ed5..acc3be1de4 100644 --- a/org.springframework.integration/src/test/java/org/springframework/integration/router/AggregatingMessageHandlerTests.java +++ b/org.springframework.integration/src/test/java/org/springframework/integration/router/AggregatingMessageHandlerTests.java @@ -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);