diff --git a/spring-integration-core/src/test/java/org/springframework/integration/bus/FixedDelayConsumerTests.java b/spring-integration-core/src/test/java/org/springframework/integration/bus/FixedDelayConsumerTests.java
index 8b4bef0a51..08840fe9dc 100644
--- a/spring-integration-core/src/test/java/org/springframework/integration/bus/FixedDelayConsumerTests.java
+++ b/spring-integration-core/src/test/java/org/springframework/integration/bus/FixedDelayConsumerTests.java
@@ -65,7 +65,7 @@ public class FixedDelayConsumerTests {
 		for (int i = 0; i < messagesToSend; i++) {
 			channel.send(new GenericMessage<String>(1, "test " + (i+1)));
 		}
-		latch.await(1000, TimeUnit.MILLISECONDS);
+		latch.await(2000, TimeUnit.MILLISECONDS);
 		assertEquals(messagesToSend, counter.get());
 	}
 
diff --git a/spring-integration-core/src/test/java/org/springframework/integration/channel/PointToPointChannelTests.java b/spring-integration-core/src/test/java/org/springframework/integration/channel/PointToPointChannelTests.java
index 0ed295f04b..53a59db6e8 100644
--- a/spring-integration-core/src/test/java/org/springframework/integration/channel/PointToPointChannelTests.java
+++ b/spring-integration-core/src/test/java/org/springframework/integration/channel/PointToPointChannelTests.java
@@ -204,7 +204,7 @@ public class PointToPointChannelTests {
 					public boolean accept(Message<?> message) {
 						return (((Integer)message.getId()).intValue() == 3);
 					}
-				}, 100);
+				}, 500);
 				messageRef.set(message);
 				latch.countDown();
 			}