INT-3355 Redis Tests Minor Polishing
JIRA: https://jira.spring.io/browse/INT-3355 Minor issues/typos noticed while back porting.
This commit is contained in:
@@ -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);
|
||||
|
||||
@@ -429,6 +429,7 @@ public class RedisStoreOutboundChannelAdapterIntegrationTests extends RedisAvail
|
||||
String hello = redisMap.get("foo");
|
||||
|
||||
assertEquals("hello, world!", hello);
|
||||
this.deleteKey(jcf, "bar");
|
||||
context.close();
|
||||
}
|
||||
|
||||
|
||||
@@ -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);
|
||||
|
||||
Reference in New Issue
Block a user