Fixed - RedissonSessionRepository process changes of unnecessary keys #1864

pull/1871/head
Nikita Koksharov 6 years ago
parent 959fad1771
commit ad92d39b89

@ -249,11 +249,11 @@ public class RedissonSessionRepository implements FindByIndexNameSessionReposito
publishEvent(new SessionCreatedEvent(this, session));
}
} else if (deletedTopic.getPatternNames().contains(pattern.toString())) {
if (!body.contains(":")) {
if (!body.startsWith(keyPrefix)) {
return;
}
String id = body.split(":")[1];
String id = body.split(keyPrefix)[1];
RedissonSession session = new RedissonSession(keyPrefix, id);
if (session.load()) {
session.clearPrincipal();
@ -262,11 +262,11 @@ public class RedissonSessionRepository implements FindByIndexNameSessionReposito
publishEvent(new SessionDeletedEvent(this, id));
}
} else if (expiredTopic.getPatternNames().contains(pattern.toString())) {
if (!body.contains(":")) {
if (!body.startsWith(keyPrefix)) {
return;
}
String id = body.split(":")[1];
String id = body.split(keyPrefix)[1];
RedissonSession session = new RedissonSession(keyPrefix, id);
if (session.load()) {
session.clearPrincipal();

Loading…
Cancel
Save