diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/bus/MessageBusTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/bus/MessageBusTests.java
index 04c46d5427..c2da1503a6 100644
--- a/org.springframework.integration/src/test/java/org/springframework/integration/bus/MessageBusTests.java
+++ b/org.springframework.integration/src/test/java/org/springframework/integration/bus/MessageBusTests.java
@@ -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);
diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/gateway/RequestReplyTemplateTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/gateway/RequestReplyTemplateTests.java
index 00feb50bbb..873dee2b4c 100644
--- a/org.springframework.integration/src/test/java/org/springframework/integration/gateway/RequestReplyTemplateTests.java
+++ b/org.springframework.integration/src/test/java/org/springframework/integration/gateway/RequestReplyTemplateTests.java
@@ -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"));