From cae8378ed6ff6a7975ace30b93460ec4398a9e67 Mon Sep 17 00:00:00 2001 From: seakider Date: Mon, 10 Mar 2025 21:58:51 +0800 Subject: [PATCH] Fixed - Inconsistent MaxInactiveInterval Setting in Sessions in multi-node Signed-off-by: seakider --- .../src/main/java/org/redisson/tomcat/RedissonSession.java | 7 +------ .../src/main/java/org/redisson/tomcat/RedissonSession.java | 7 +------ .../src/main/java/org/redisson/tomcat/RedissonSession.java | 7 +------ .../src/main/java/org/redisson/tomcat/RedissonSession.java | 7 +------ .../src/main/java/org/redisson/tomcat/RedissonSession.java | 7 +------ 5 files changed, 5 insertions(+), 30 deletions(-) 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) {