From cc101560f05eeafbb778d4024d402c2b2ca462fa Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Tue, 15 Jan 2019 13:19:49 +0300 Subject: [PATCH] Improvement - Spring Session key encoding changed to String --- .../redisson/spring/session/RedissonSessionRepository.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/redisson/src/main/java/org/redisson/spring/session/RedissonSessionRepository.java b/redisson/src/main/java/org/redisson/spring/session/RedissonSessionRepository.java index 785d1d4c4..dcd9ce7c7 100644 --- a/redisson/src/main/java/org/redisson/spring/session/RedissonSessionRepository.java +++ b/redisson/src/main/java/org/redisson/spring/session/RedissonSessionRepository.java @@ -29,6 +29,7 @@ import org.redisson.api.RTopic; import org.redisson.api.RedissonClient; import org.redisson.api.listener.PatternMessageListener; import org.redisson.client.codec.StringCodec; +import org.redisson.codec.CompositeCodec; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.context.ApplicationEvent; @@ -59,7 +60,7 @@ public class RedissonSessionRepository implements FindByIndexNameSessionReposito public RedissonSession(String keyPrefix) { this.delegate = new MapSession(); - map = redisson.getMap(keyPrefix + delegate.getId()); + map = redisson.getMap(keyPrefix + delegate.getId(), new CompositeCodec(StringCodec.INSTANCE, redisson.getConfig().getCodec())); principalName = resolvePrincipal(delegate); Map newMap = new HashMap(3); @@ -83,7 +84,7 @@ public class RedissonSessionRepository implements FindByIndexNameSessionReposito public RedissonSession(String keyPrefix, String sessionId) { this.delegate = new MapSession(sessionId); - map = redisson.getMap(keyPrefix + sessionId); + map = redisson.getMap(keyPrefix + sessionId, new CompositeCodec(StringCodec.INSTANCE, redisson.getConfig().getCodec())); principalName = resolvePrincipal(delegate); } @@ -378,7 +379,7 @@ public class RedissonSessionRepository implements FindByIndexNameSessionReposito private RSet getPrincipalSet(String indexValue) { String principalKey = getPrincipalKey(indexValue); - return redisson.getSet(principalKey); + return redisson.getSet(principalKey, StringCodec.INSTANCE); } }