+ enable binary pubsub test
This commit is contained in:
@@ -45,12 +45,9 @@ public class PubSubTestParams {
|
||||
jedisConnFactory.afterPropertiesSet();
|
||||
|
||||
RedisTemplate<String, String> stringTemplate = new StringRedisTemplate(jedisConnFactory);
|
||||
//RedisTemplate<String, Person> personTemplate = new RedisTemplate<String, Person>(jedisConnFactory);
|
||||
RedisTemplate<String, Person> personTemplate = new RedisTemplate<String, Person>(jedisConnFactory);
|
||||
|
||||
|
||||
// FIXME: DATAKV-24
|
||||
return Arrays.asList(new Object[][] { { stringFactory, stringTemplate }
|
||||
//, { personFactory, personTemplate }
|
||||
});
|
||||
return Arrays.asList(new Object[][] { { stringFactory, stringTemplate }, { personFactory, personTemplate } });
|
||||
}
|
||||
}
|
||||
|
||||
@@ -66,7 +66,7 @@ public class PubSubTests<T> {
|
||||
|
||||
@Before
|
||||
public void setUp() throws Exception {
|
||||
//adapter.setSerializer(template.getValueSerializer());
|
||||
adapter.setSerializer(template.getValueSerializer());
|
||||
|
||||
container = new RedisMessageListenerContainer();
|
||||
container.setConnectionFactory(template.getConnectionFactory());
|
||||
|
||||
Reference in New Issue
Block a user