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);