See gh-1128
This commit is contained in:
Vedran Pavic
2018-09-13 08:55:13 +02:00
parent 5d0775b802
commit 1a3da5944d

View File

@@ -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);