diff --git a/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/RedisStoreInboundChannelAdapterIntegrationTests.java b/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/RedisStoreInboundChannelAdapterIntegrationTests.java
index 18c94b5831..cbd271a731 100644
--- a/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/RedisStoreInboundChannelAdapterIntegrationTests.java
+++ b/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/RedisStoreInboundChannelAdapterIntegrationTests.java
@@ -74,7 +74,7 @@ public class RedisStoreInboundChannelAdapterIntegrationTests extends RedisAvaila
 	@Test
 	@RedisAvailable
 	@SuppressWarnings("unchecked")
-	// syncronization commit renames the list
+	// synchronization commit renames the list
 	public void testListInboundConfigurationWithSynchronization() throws Exception{
 		RedisConnectionFactory jcf = this.getConnectionFactoryForTest();
 		StringRedisTemplate template = this.createStringRedisTemplate(jcf);
@@ -101,7 +101,7 @@ public class RedisStoreInboundChannelAdapterIntegrationTests extends RedisAvaila
 
 	@Test
 	@RedisAvailable
-	// syncronization rollback renames the list
+	// synchronization rollback renames the list
 	public void testListInboundConfigurationWithSynchronizationAndRollback() throws Exception{
 		RedisConnectionFactory jcf = this.getConnectionFactoryForTest();
 		StringRedisTemplate template = this.createStringRedisTemplate(jcf);
@@ -138,7 +138,7 @@ public class RedisStoreInboundChannelAdapterIntegrationTests extends RedisAvaila
 	@Test
 	@RedisAvailable
 	@SuppressWarnings("unchecked")
-	// syncronization commit renames the list
+	// synchronization commit renames the list
 	public void testListInboundConfigurationWithSynchronizationAndTemplate() throws Exception{
 		RedisConnectionFactory jcf = this.getConnectionFactoryForTest();
 		StringRedisTemplate template = this.createStringRedisTemplate(jcf);
diff --git a/spring-integration-redis/src/test/java/org/springframework/integration/redis/outbound/RedisStoreOutboundChannelAdapterIntegrationTests.java b/spring-integration-redis/src/test/java/org/springframework/integration/redis/outbound/RedisStoreOutboundChannelAdapterIntegrationTests.java
index 7865ad2e5b..5f9b5cceee 100644
--- a/spring-integration-redis/src/test/java/org/springframework/integration/redis/outbound/RedisStoreOutboundChannelAdapterIntegrationTests.java
+++ b/spring-integration-redis/src/test/java/org/springframework/integration/redis/outbound/RedisStoreOutboundChannelAdapterIntegrationTests.java
@@ -429,6 +429,7 @@ public class RedisStoreOutboundChannelAdapterIntegrationTests extends RedisAvail
 		String hello = redisMap.get("foo");
 
 		assertEquals("hello, world!", hello);
+		this.deleteKey(jcf, "bar");
 		context.close();
 	}
 
diff --git a/spring-integration-redis/src/test/java/org/springframework/integration/redis/store/RedisMessageGroupStoreTests.java b/spring-integration-redis/src/test/java/org/springframework/integration/redis/store/RedisMessageGroupStoreTests.java
index 394b6569f8..77916b22a7 100644
--- a/spring-integration-redis/src/test/java/org/springframework/integration/redis/store/RedisMessageGroupStoreTests.java
+++ b/spring-integration-redis/src/test/java/org/springframework/integration/redis/store/RedisMessageGroupStoreTests.java
@@ -361,8 +361,6 @@ public class RedisMessageGroupStoreTests extends RedisAvailableTests {
 	@Test
 	@RedisAvailable
 	public void testWithAggregatorWithShutdown(){
-		this.getConnectionFactoryForTest(); // for this test it only ensures that DB was flushed before test
-
 		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("redis-aggregator-config.xml", this.getClass());
 		MessageChannel input = context.getBean("inputChannel", MessageChannel.class);
 		QueueChannel output = context.getBean("outputChannel", QueueChannel.class);