Spring/spring-session
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Optimize HazelcastSessionRepository.SessionUpdateEntryProcessor

Browse Source 
Closes gh-947
This commit is contained in:
Vedran Pavic
2017-12-01 08:37:03 +01:00
parent 77bb9dfdb1
commit 27283e29d5
1 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
spring-session-hazelcast/src/main/java/org/springframework/session/hazelcast/HazelcastSessionRepository.java
View File

@@ -233,8 +233,9 @@ public class HazelcastSessionRepository implements
session.getMaxInactiveInterval().getSeconds(), TimeUnit.SECONDS);
}
else if (session.changed) {
this.sessions.executeOnKey(session.getId(), new SessionUpdateEntryProcessor(
session.getDelegate(), session.delta));
this.sessions.executeOnKey(session.getId(),
new SessionUpdateEntryProcessor(session.getLastAccessedTime(),
session.getMaxInactiveInterval(), session.delta));
}
session.clearFlags();
}
@@ -435,20 +436,24 @@ public class HazelcastSessionRepository implements
private static final class SessionUpdateEntryProcessor
extends AbstractEntryProcessor<String, MapSession> {
private final MapSession session;
private final Instant lastAccessedTime;
private final Duration maxInactiveInterval;
private final Map<String, Object> delta;
SessionUpdateEntryProcessor(MapSession session, Map<String, Object> delta) {
this.session = session;
SessionUpdateEntryProcessor(Instant lastAccessedTime,
Duration maxInactiveInterval, Map<String, Object> delta) {
this.lastAccessedTime = lastAccessedTime;
this.maxInactiveInterval = maxInactiveInterval;
this.delta = delta;
}
@Override
public Object process(Map.Entry<String, MapSession> entry) {
MapSession value = entry.getValue();
value.setLastAccessedTime(this.session.getLastAccessedTime());
value.setMaxInactiveInterval(this.session.getMaxInactiveInterval());
value.setLastAccessedTime(this.lastAccessedTime);
value.setMaxInactiveInterval(this.maxInactiveInterval);
for (final Map.Entry<String, Object> attribute : this.delta.entrySet()) {
if (attribute.getValue() != null) {
value.setAttribute(attribute.getKey(), attribute.getValue());