Allow default RedisSerializer to be specified

Fixes gh-283
This commit is contained in:
Rob Winch
2015-08-31 10:26:48 -05:00
parent 134d23bb07
commit 489a26c14c
2 changed files with 83 additions and 0 deletions

View File

@@ -35,6 +35,7 @@ import org.springframework.data.redis.core.RedisOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.session.config.annotation.web.http.SpringHttpSessionConfiguration;
@@ -67,6 +68,8 @@ public class RedisHttpSessionConfiguration extends SpringHttpSessionConfiguratio
private String redisNamespace = "";
private RedisSerializer<Object> defaultRedisSerializer;
@Bean
public RedisMessageListenerContainer redisMessageListenerContainer(
RedisConnectionFactory connectionFactory, RedisOperationsSessionRepository messageListener) {
@@ -84,6 +87,9 @@ public class RedisHttpSessionConfiguration extends SpringHttpSessionConfiguratio
RedisTemplate<Object, Object> template = new RedisTemplate<Object, Object>();
template.setKeySerializer(new StringRedisSerializer());
template.setHashKeySerializer(new StringRedisSerializer());
if(defaultRedisSerializer != null) {
template.setDefaultSerializer(defaultRedisSerializer);
}
template.setConnectionFactory(connectionFactory);
return template;
}
@@ -173,6 +179,12 @@ public class RedisHttpSessionConfiguration extends SpringHttpSessionConfiguratio
this.configureRedisAction = configureRedisAction;
}
@Autowired(required = false)
@Qualifier("defaultRedisSerializer")
public void setDefaultRedisSerializer(RedisSerializer<Object> defaultRedisSerializer) {
this.defaultRedisSerializer = defaultRedisSerializer;
}
/* (non-Javadoc)
* @see org.springframework.beans.factory.BeanClassLoaderAware#setBeanClassLoader(java.lang.ClassLoader)
*/