From 1a3da5944d8958540e2de62bb20091b842f0bf12 Mon Sep 17 00:00:00 2001 From: Vedran Pavic Date: Thu, 13 Sep 2018 08:55:13 +0200 Subject: [PATCH] Polish See gh-1128 --- .../data/redis/RedisOperationsSessionRepository.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/spring-session-data-redis/src/main/java/org/springframework/session/data/redis/RedisOperationsSessionRepository.java b/spring-session-data-redis/src/main/java/org/springframework/session/data/redis/RedisOperationsSessionRepository.java index 8b07e5e3..28aecd1a 100644 --- a/spring-session-data-redis/src/main/java/org/springframework/session/data/redis/RedisOperationsSessionRepository.java +++ b/spring-session-data-redis/src/main/java/org/springframework/session/data/redis/RedisOperationsSessionRepository.java @@ -391,6 +391,10 @@ public class RedisOperationsSessionRepository implements this.redisFlushMode = redisFlushMode; } + /** + * Sets the database index to use. Defaults to {@link #DEFAULT_DATABASE}. + * @param database the database index to use + */ public void setDatabase(int database) { this.database = database; configureSessionChannels(); @@ -541,8 +545,8 @@ public class RedisOperationsSessionRepository implements return; } - boolean isDeleted = (this.sessionDeletedChannel).equals(channel); - if (isDeleted || (this.sessionExpiredChannel).equals(channel)) { + boolean isDeleted = channel.equals(this.sessionDeletedChannel); + if (isDeleted || channel.equals(this.sessionExpiredChannel)) { int beginIndex = body.lastIndexOf(":") + 1; int endIndex = body.length(); String sessionId = body.substring(beginIndex, endIndex);