github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fixed - Inconsistent MaxInactiveInterval Setting in Sessions in multi-node

Browse Source 
Signed-off-by: seakider <seakider@gmail.com>
pull/6478/head
seakider 3 days ago
parent 4ce7820fdc
commit cae8378ed6
5 changed files with 5 additions and 30 deletions
Show Stats Download Patch File Download Diff File

7
redisson-tomcat/redisson-tomcat-10/src/main/java/org/redisson/tomcat/RedissonSession.java
Unescape Escape View File

@ -263,7 +263,7 @@ public class RedissonSession extends StandardSession {
return; return;
} }
m.fastPut(name, value); m.fastPut(name, value);
if (readMode == ReadMode.MEMORY && this.broadcastSessionUpdates || this.broadcastSessionEvents) { if (readMode == ReadMode.REDIS || this.broadcastSessionUpdates) {
try { try {
Encoder encoder = m.getCodec().getMapValueEncoder(); Encoder encoder = m.getCodec().getMapValueEncoder();
topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder)); topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder));
@ -336,11 +336,6 @@ public class RedissonSession extends StandardSession {
} }
} }
public void superSetAttribute(String name, Object value, boolean notify) {
super.setAttribute(name, value, notify);
}
@Override @Override
public void setAttribute(String name, Object value, boolean notify) { public void setAttribute(String name, Object value, boolean notify) {
super.setAttribute(name, value, notify); super.setAttribute(name, value, notify);

7
redisson-tomcat/redisson-tomcat-11/src/main/java/org/redisson/tomcat/RedissonSession.java
Unescape Escape View File

@ -263,7 +263,7 @@ public class RedissonSession extends StandardSession {
return; return;
} }
m.fastPut(name, value); m.fastPut(name, value);
if (readMode == ReadMode.MEMORY && this.broadcastSessionUpdates || this.broadcastSessionEvents) { if (readMode == ReadMode.REDIS || this.broadcastSessionUpdates) {
try { try {
Encoder encoder = m.getCodec().getMapValueEncoder(); Encoder encoder = m.getCodec().getMapValueEncoder();
topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder)); topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder));
@ -336,11 +336,6 @@ public class RedissonSession extends StandardSession {
} }
} }
public void superSetAttribute(String name, Object value, boolean notify) {
super.setAttribute(name, value, notify);
}
@Override @Override
public void setAttribute(String name, Object value, boolean notify) { public void setAttribute(String name, Object value, boolean notify) {
super.setAttribute(name, value, notify); super.setAttribute(name, value, notify);

7
redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSession.java
Unescape Escape View File

@ -258,7 +258,7 @@ public class RedissonSession extends StandardSession {
return; return;
} }
m.fastPut(name, value); m.fastPut(name, value);
if (readMode == ReadMode.MEMORY && this.broadcastSessionUpdates || this.broadcastSessionEvents) { if (readMode == ReadMode.REDIS || this.broadcastSessionUpdates) {
try { try {
Encoder encoder = m.getCodec().getMapValueEncoder(); Encoder encoder = m.getCodec().getMapValueEncoder();
topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder)); topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder));
@ -331,11 +331,6 @@ public class RedissonSession extends StandardSession {
} }
} }
public void superSetAttribute(String name, Object value, boolean notify) {
super.setAttribute(name, value, notify);
}
@Override @Override
public void setAttribute(String name, Object value, boolean notify) { public void setAttribute(String name, Object value, boolean notify) {
super.setAttribute(name, value, notify); super.setAttribute(name, value, notify);

7
redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSession.java
Unescape Escape View File

@ -258,7 +258,7 @@ public class RedissonSession extends StandardSession {
return; return;
} }
m.fastPut(name, value); m.fastPut(name, value);
if (readMode == ReadMode.MEMORY && this.broadcastSessionUpdates || this.broadcastSessionEvents) { if (readMode == ReadMode.REDIS || this.broadcastSessionUpdates) {
try { try {
Encoder encoder = m.getCodec().getMapValueEncoder(); Encoder encoder = m.getCodec().getMapValueEncoder();
topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder)); topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder));
@ -331,11 +331,6 @@ public class RedissonSession extends StandardSession {
} }
} }
public void superSetAttribute(String name, Object value, boolean notify) {
super.setAttribute(name, value, notify);
}
@Override @Override
public void setAttribute(String name, Object value, boolean notify) { public void setAttribute(String name, Object value, boolean notify) {
super.setAttribute(name, value, notify); super.setAttribute(name, value, notify);

7
redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSession.java
Unescape Escape View File

@ -258,7 +258,7 @@ public class RedissonSession extends StandardSession {
return; return;
} }
m.fastPut(name, value); m.fastPut(name, value);
if (readMode == ReadMode.MEMORY && this.broadcastSessionUpdates || this.broadcastSessionEvents) { if (readMode == ReadMode.REDIS || this.broadcastSessionUpdates) {
try { try {
Encoder encoder = m.getCodec().getMapValueEncoder(); Encoder encoder = m.getCodec().getMapValueEncoder();
topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder)); topic.publish(new AttributeUpdateMessage(redissonManager.getNodeId(), getId(), name, value, encoder));
@ -331,11 +331,6 @@ public class RedissonSession extends StandardSession {
} }
} }
public void superSetAttribute(String name, Object value, boolean notify) {
super.setAttribute(name, value, notify);
}
@Override @Override
public void setAttribute(String name, Object value, boolean notify) { public void setAttribute(String name, Object value, boolean notify) {
super.setAttribute(name, value, notify); super.setAttribute(name, value, notify);

Write Preview
Loading…
Cancel
Save