diff --git a/redisson-tomcat/redisson-tomcat-6/src/main/java/org/redisson/tomcat/RedissonSessionManager.java b/redisson-tomcat/redisson-tomcat-6/src/main/java/org/redisson/tomcat/RedissonSessionManager.java index 8f172ee45..3cf6ffb6f 100644 --- a/redisson-tomcat/redisson-tomcat-6/src/main/java/org/redisson/tomcat/RedissonSessionManager.java +++ b/redisson-tomcat/redisson-tomcat-6/src/main/java/org/redisson/tomcat/RedissonSessionManager.java @@ -280,9 +280,8 @@ public class RedissonSessionManager extends ManagerBase implements Lifecycle { if (msg instanceof AttributesPutAllMessage) { AttributesPutAllMessage m = (AttributesPutAllMessage) msg; - for (Entry entry : m.getAttrs(codecToUse.getMapValueDecoder()).entrySet()) { - session.superSetAttribute(entry.getKey(), entry.getValue(), true); - } + Map attrs = m.getAttrs(codecToUse.getMapValueDecoder()); + session.load(attrs); } if (msg instanceof AttributeUpdateMessage) { diff --git a/redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSessionManager.java b/redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSessionManager.java index 75ed1e751..ec75c0d7f 100644 --- a/redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSessionManager.java +++ b/redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSessionManager.java @@ -260,9 +260,8 @@ public class RedissonSessionManager extends ManagerBase { if (msg instanceof AttributesPutAllMessage) { AttributesPutAllMessage m = (AttributesPutAllMessage) msg; - for (Entry entry : m.getAttrs(codecToUse.getMapValueDecoder()).entrySet()) { - session.superSetAttribute(entry.getKey(), entry.getValue(), true); - } + Map attrs = m.getAttrs(codecToUse.getMapValueDecoder()); + session.load(attrs); } if (msg instanceof AttributeUpdateMessage) { diff --git a/redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSessionManager.java b/redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSessionManager.java index efe49413f..17eaa08a9 100644 --- a/redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSessionManager.java +++ b/redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSessionManager.java @@ -259,9 +259,8 @@ public class RedissonSessionManager extends ManagerBase { if (msg instanceof AttributesPutAllMessage) { AttributesPutAllMessage m = (AttributesPutAllMessage) msg; - for (Entry entry : m.getAttrs(codecToUse.getMapValueDecoder()).entrySet()) { - session.superSetAttribute(entry.getKey(), entry.getValue(), true); - } + Map attrs = m.getAttrs(codecToUse.getMapValueDecoder()); + session.load(attrs); } if (msg instanceof AttributeUpdateMessage) { diff --git a/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java b/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java index efe49413f..17eaa08a9 100644 --- a/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java +++ b/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java @@ -259,9 +259,8 @@ public class RedissonSessionManager extends ManagerBase { if (msg instanceof AttributesPutAllMessage) { AttributesPutAllMessage m = (AttributesPutAllMessage) msg; - for (Entry entry : m.getAttrs(codecToUse.getMapValueDecoder()).entrySet()) { - session.superSetAttribute(entry.getKey(), entry.getValue(), true); - } + Map attrs = m.getAttrs(codecToUse.getMapValueDecoder()); + session.load(attrs); } if (msg instanceof AttributeUpdateMessage) {