diff --git a/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/store/DelayerHandlerRescheduleIntegrationTests-context.xml b/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/store/DelayerHandlerRescheduleIntegrationTests-context.xml
index f285d8c8a6..8f0e7ef597 100644
--- a/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/store/DelayerHandlerRescheduleIntegrationTests-context.xml
+++ b/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/store/DelayerHandlerRescheduleIntegrationTests-context.xml
@@ -16,7 +16,7 @@
 	<delayer id="#{T (org.springframework.integration.gemfire.store.DelayerHandlerRescheduleIntegrationTests).DELAYER_ID}"
 			 input-channel="input"
 			 output-channel="output"
-			 default-delay="500"
+			 default-delay="10000"
 			 message-store="messageStore"/>
 
 </beans:beans>
diff --git a/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/store/DelayerHandlerRescheduleIntegrationTests.java b/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/store/DelayerHandlerRescheduleIntegrationTests.java
index 795fdf20fc..dbddb47e84 100644
--- a/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/store/DelayerHandlerRescheduleIntegrationTests.java
+++ b/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/store/DelayerHandlerRescheduleIntegrationTests.java
@@ -23,10 +23,9 @@ import java.util.concurrent.TimeUnit;
 
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
+import org.junit.Rule;
 import org.junit.Test;
 
-import com.gemstone.gemfire.cache.Cache;
-
 import org.springframework.context.support.AbstractApplicationContext;
 import org.springframework.context.support.ClassPathXmlApplicationContext;
 import org.springframework.data.gemfire.CacheFactoryBean;
@@ -38,9 +37,12 @@ import org.springframework.integration.handler.DelayHandler;
 import org.springframework.integration.store.MessageGroup;
 import org.springframework.integration.store.MessageGroupStore;
 import org.springframework.integration.support.MessageBuilder;
+import org.springframework.integration.test.support.LongRunningIntegrationTest;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 import org.springframework.util.Assert;
 
+import com.gemstone.gemfire.cache.Cache;
+
 
 /**
  * @author Artem Bilan
@@ -52,6 +54,9 @@ public class DelayerHandlerRescheduleIntegrationTests {
 
 	public static Cache cache;
 
+	@Rule
+	public LongRunningIntegrationTest longTests = new LongRunningIntegrationTest();
+
 	@BeforeClass
 	public static void startUp() throws Exception {
 		CacheFactoryBean cacheFactoryBean = new CacheFactoryBean();
@@ -109,12 +114,12 @@ public class DelayerHandlerRescheduleIntegrationTests {
 
 		PollableChannel output = context.getBean("output", PollableChannel.class);
 
-		Message<?> message = output.receive(10000);
+		Message<?> message = output.receive(20000);
 		assertNotNull(message);
 
 		Object payload1 = message.getPayload();
 
-		message = output.receive(10000);
+		message = output.receive(20000);
 		assertNotNull(message);
 		Object payload2 = message.getPayload();
 		assertNotSame(payload1, payload2);
diff --git a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/DelayerHandlerRescheduleIntegrationTests-context.xml b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/DelayerHandlerRescheduleIntegrationTests-context.xml
index b49a6b072b..f72f70736c 100644
--- a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/DelayerHandlerRescheduleIntegrationTests-context.xml
+++ b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/DelayerHandlerRescheduleIntegrationTests-context.xml
@@ -20,7 +20,7 @@
 	<delayer id="#{T (org.springframework.integration.jdbc.DelayerHandlerRescheduleIntegrationTests).DELAYER_ID}"
 			 input-channel="input"
 			 output-channel="output"
-			 default-delay="500"
+			 default-delay="10000"
 			 message-store="messageStore"/>
 
 	<channel id="transactionalDelayerOutput"/>
diff --git a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/DelayerHandlerRescheduleIntegrationTests.java b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/DelayerHandlerRescheduleIntegrationTests.java
index 4692650213..af7ffb28cc 100644
--- a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/DelayerHandlerRescheduleIntegrationTests.java
+++ b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/DelayerHandlerRescheduleIntegrationTests.java
@@ -24,6 +24,7 @@ import java.util.concurrent.TimeUnit;
 
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
+import org.junit.Rule;
 import org.junit.Test;
 
 import org.springframework.context.support.AbstractApplicationContext;
@@ -38,6 +39,7 @@ import org.springframework.integration.handler.DelayHandler;
 import org.springframework.integration.store.MessageGroup;
 import org.springframework.integration.store.MessageGroupStore;
 import org.springframework.integration.support.MessageBuilder;
+import org.springframework.integration.test.support.LongRunningIntegrationTest;
 import org.springframework.integration.util.UUIDConverter;
 import org.springframework.jdbc.datasource.embedded.EmbeddedDatabase;
 import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseBuilder;
@@ -57,6 +59,9 @@ public class DelayerHandlerRescheduleIntegrationTests {
 
 	public static EmbeddedDatabase dataSource;
 
+	@Rule
+	public LongRunningIntegrationTest longTests = new LongRunningIntegrationTest();
+
 	@BeforeClass
 	public static void init() {
 		dataSource = new EmbeddedDatabaseBuilder()
@@ -115,12 +120,12 @@ public class DelayerHandlerRescheduleIntegrationTests {
 
 		PollableChannel output = context.getBean("output", PollableChannel.class);
 
-		Message<?> message = output.receive(10000);
+		Message<?> message = output.receive(20000);
 		assertNotNull(message);
 
 		Object payload1 = message.getPayload();
 
-		message = output.receive(10000);
+		message = output.receive(20000);
 		assertNotNull(message);
 		Object payload2 = message.getPayload();
 		assertNotSame(payload1, payload2);
diff --git a/spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/store/DelayerHandlerRescheduleIntegrationTests-context.xml b/spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/store/DelayerHandlerRescheduleIntegrationTests-context.xml
index b9e2ab74fb..a6ce73f3ad 100644
--- a/spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/store/DelayerHandlerRescheduleIntegrationTests-context.xml
+++ b/spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/store/DelayerHandlerRescheduleIntegrationTests-context.xml
@@ -23,7 +23,7 @@
 	<delayer id="#{T (org.springframework.integration.mongodb.store.DelayerHandlerRescheduleIntegrationTests).DELAYER_ID}"
 			 input-channel="input"
 			 output-channel="output"
-			 default-delay="500"
+			 default-delay="10000"
 			 message-store="messageStore"/>
 
 </beans:beans>
diff --git a/spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/store/DelayerHandlerRescheduleIntegrationTests.java b/spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/store/DelayerHandlerRescheduleIntegrationTests.java
index 2fb73b724f..87a7637d26 100644
--- a/spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/store/DelayerHandlerRescheduleIntegrationTests.java
+++ b/spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/store/DelayerHandlerRescheduleIntegrationTests.java
@@ -23,6 +23,7 @@ import static org.junit.Assert.fail;
 import java.util.Iterator;
 import java.util.concurrent.TimeUnit;
 
+import org.junit.Rule;
 import org.junit.Test;
 
 import org.hamcrest.Matchers;
@@ -39,6 +40,7 @@ import org.springframework.integration.mongodb.rules.MongoDbAvailableTests;
 import org.springframework.integration.store.MessageGroup;
 import org.springframework.integration.store.MessageGroupStore;
 import org.springframework.integration.support.MessageBuilder;
+import org.springframework.integration.test.support.LongRunningIntegrationTest;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 
 /**
@@ -49,6 +51,9 @@ public class DelayerHandlerRescheduleIntegrationTests extends MongoDbAvailableTe
 
 	public static final String DELAYER_ID = "delayerWithMongoMS";
 
+	@Rule
+	public LongRunningIntegrationTest longTests = new LongRunningIntegrationTest();
+
 	@Test
 	@MongoDbAvailable
 	@SuppressWarnings("unchecked")
@@ -101,12 +106,12 @@ public class DelayerHandlerRescheduleIntegrationTests extends MongoDbAvailableTe
 
 		PollableChannel output = context.getBean("output", PollableChannel.class);
 
-		Message<?> message = output.receive(10000);
+		Message<?> message = output.receive(20000);
 		assertNotNull(message);
 
 		Object payload1 = message.getPayload();
 
-		message = output.receive(10000);
+		message = output.receive(20000);
 		assertNotNull(message);
 		Object payload2 = message.getPayload();
 		assertNotSame(payload1, payload2);
diff --git a/spring-integration-redis/src/test/java/org/springframework/integration/redis/store/DelayerHandlerRescheduleIntegrationTests-context.xml b/spring-integration-redis/src/test/java/org/springframework/integration/redis/store/DelayerHandlerRescheduleIntegrationTests-context.xml
index 80bf41dcf2..00494293a3 100644
--- a/spring-integration-redis/src/test/java/org/springframework/integration/redis/store/DelayerHandlerRescheduleIntegrationTests-context.xml
+++ b/spring-integration-redis/src/test/java/org/springframework/integration/redis/store/DelayerHandlerRescheduleIntegrationTests-context.xml
@@ -20,7 +20,7 @@
 	<delayer id="#{T (org.springframework.integration.redis.store.DelayerHandlerRescheduleIntegrationTests).DELAYER_ID}"
 			 input-channel="input"
 			 output-channel="output"
-			 default-delay="500"
+			 default-delay="10000"
 			 message-store="messageStore"/>
 
 </beans:beans>
diff --git a/spring-integration-redis/src/test/java/org/springframework/integration/redis/store/DelayerHandlerRescheduleIntegrationTests.java b/spring-integration-redis/src/test/java/org/springframework/integration/redis/store/DelayerHandlerRescheduleIntegrationTests.java
index 58a68bcb79..ad4d9123a1 100644
--- a/spring-integration-redis/src/test/java/org/springframework/integration/redis/store/DelayerHandlerRescheduleIntegrationTests.java
+++ b/spring-integration-redis/src/test/java/org/springframework/integration/redis/store/DelayerHandlerRescheduleIntegrationTests.java
@@ -21,6 +21,7 @@ import static org.junit.Assert.fail;
 
 import java.util.concurrent.TimeUnit;
 
+import org.junit.Rule;
 import org.junit.Test;
 
 import org.springframework.context.support.AbstractApplicationContext;
@@ -35,6 +36,7 @@ import org.springframework.integration.redis.rules.RedisAvailableTests;
 import org.springframework.integration.store.MessageGroup;
 import org.springframework.integration.store.MessageGroupStore;
 import org.springframework.integration.support.MessageBuilder;
+import org.springframework.integration.test.support.LongRunningIntegrationTest;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 
 /**
@@ -45,7 +47,8 @@ public class DelayerHandlerRescheduleIntegrationTests extends RedisAvailableTest
 
 	public static final String DELAYER_ID = "delayerWithRedisMS";
 
-
+	@Rule
+	public LongRunningIntegrationTest longTests = new LongRunningIntegrationTest();
 
 	@Test
 	@RedisAvailable
@@ -95,12 +98,12 @@ public class DelayerHandlerRescheduleIntegrationTests extends RedisAvailableTest
 
 		PollableChannel output = context.getBean("output", PollableChannel.class);
 
-		Message<?> message = output.receive(10000);
+		Message<?> message = output.receive(20000);
 		assertNotNull(message);
 
 		Object payload1 = message.getPayload();
 
-		message = output.receive(10000);
+		message = output.receive(20000);
 		assertNotNull(message);
 		Object payload2 = message.getPayload();
 		assertNotSame(payload1, payload2);