diff --git a/redisson-tomcat/redisson-tomcat-10/src/main/java/org/redisson/tomcat/RedissonSession.java b/redisson-tomcat/redisson-tomcat-10/src/main/java/org/redisson/tomcat/RedissonSession.java index 4e90adede..191d8c06b 100644 --- a/redisson-tomcat/redisson-tomcat-10/src/main/java/org/redisson/tomcat/RedissonSession.java +++ b/redisson-tomcat/redisson-tomcat-10/src/main/java/org/redisson/tomcat/RedissonSession.java @@ -263,7 +263,7 @@ public class RedissonSession extends StandardSession { return; } m.fastPut(name, value); - if (readMode == ReadMode.MEMORY && this.broadcastSessionUpdates || this.broadcastSessionEvents) { + if (readMode == ReadMode.REDIS || this.broadcastSessionUpdates) { try { Encoder encoder = m.getCodec().getMapValueEncoder(); topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder)); @@ -335,11 +335,6 @@ public class RedissonSession extends StandardSession { expireSession(); } } - - - public void superSetAttribute(String name, Object value, boolean notify) { - super.setAttribute(name, value, notify); - } @Override public void setAttribute(String name, Object value, boolean notify) { diff --git a/redisson-tomcat/redisson-tomcat-11/src/main/java/org/redisson/tomcat/RedissonSession.java b/redisson-tomcat/redisson-tomcat-11/src/main/java/org/redisson/tomcat/RedissonSession.java index 4e90adede..191d8c06b 100644 --- a/redisson-tomcat/redisson-tomcat-11/src/main/java/org/redisson/tomcat/RedissonSession.java +++ b/redisson-tomcat/redisson-tomcat-11/src/main/java/org/redisson/tomcat/RedissonSession.java @@ -263,7 +263,7 @@ public class RedissonSession extends StandardSession { return; } m.fastPut(name, value); - if (readMode == ReadMode.MEMORY && this.broadcastSessionUpdates || this.broadcastSessionEvents) { + if (readMode == ReadMode.REDIS || this.broadcastSessionUpdates) { try { Encoder encoder = m.getCodec().getMapValueEncoder(); topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder)); @@ -335,11 +335,6 @@ public class RedissonSession extends StandardSession { expireSession(); } } - - - public void superSetAttribute(String name, Object value, boolean notify) { - super.setAttribute(name, value, notify); - } @Override public void setAttribute(String name, Object value, boolean notify) { diff --git a/redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSession.java b/redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSession.java index 108b79332..4f7fb7c53 100644 --- a/redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSession.java +++ b/redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSession.java @@ -258,7 +258,7 @@ public class RedissonSession extends StandardSession { return; } m.fastPut(name, value); - if (readMode == ReadMode.MEMORY && this.broadcastSessionUpdates || this.broadcastSessionEvents) { + if (readMode == ReadMode.REDIS || this.broadcastSessionUpdates) { try { Encoder encoder = m.getCodec().getMapValueEncoder(); topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder)); @@ -330,11 +330,6 @@ public class RedissonSession extends StandardSession { expireSession(); } } - - - public void superSetAttribute(String name, Object value, boolean notify) { - super.setAttribute(name, value, notify); - } @Override public void setAttribute(String name, Object value, boolean notify) { diff --git a/redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSession.java b/redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSession.java index afcba2344..5cd7ddf9c 100644 --- a/redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSession.java +++ b/redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSession.java @@ -258,7 +258,7 @@ public class RedissonSession extends StandardSession { return; } m.fastPut(name, value); - if (readMode == ReadMode.MEMORY && this.broadcastSessionUpdates || this.broadcastSessionEvents) { + if (readMode == ReadMode.REDIS || this.broadcastSessionUpdates) { try { Encoder encoder = m.getCodec().getMapValueEncoder(); topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder)); @@ -330,11 +330,6 @@ public class RedissonSession extends StandardSession { expireSession(); } } - - - public void superSetAttribute(String name, Object value, boolean notify) { - super.setAttribute(name, value, notify); - } @Override public void setAttribute(String name, Object value, boolean notify) { diff --git a/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSession.java b/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSession.java index afcba2344..5cd7ddf9c 100644 --- a/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSession.java +++ b/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSession.java @@ -258,7 +258,7 @@ public class RedissonSession extends StandardSession { return; } m.fastPut(name, value); - if (readMode == ReadMode.MEMORY && this.broadcastSessionUpdates || this.broadcastSessionEvents) { + if (readMode == ReadMode.REDIS || this.broadcastSessionUpdates) { try { Encoder encoder = m.getCodec().getMapValueEncoder(); topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder)); @@ -330,11 +330,6 @@ public class RedissonSession extends StandardSession { expireSession(); } } - - - public void superSetAttribute(String name, Object value, boolean notify) { - super.setAttribute(name, value, notify); - } @Override public void setAttribute(String name, Object value, boolean notify) {