Making sure that redisson:tomcat_notified_nodes keys get an expiration on SessionDestroyedMessage.

Replicating the expiration set RedissonSession.delete().

Signed-off-by: Etienne Hardy <etienne.hardy@appdirect.com>

redisson-tomcat/redisson-tomcat-10/src/main/java/org/redisson/tomcat/RedissonSessionManager.java

@@ -34,6 +34,7 @@ import org.redisson.pubsub.PublishSubscribeService;
 
 import java.io.File;
 import java.io.IOException;
+import java.time.Duration;
 import java.util.*;
 
 /**
@@ -335,6 +336,7 @@ public class RedissonSessionManager extends ManagerBase {
                                 }
                                 RSet<String> set = getNotifiedNodes(msg.getSessionId());
                                 set.add(nodeId);
+                                set.expire(Duration.ofSeconds(60));
                             }
                             
                         }

redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSessionManager.java

@@ -34,6 +34,7 @@ import org.redisson.pubsub.PublishSubscribeService;
 import javax.servlet.http.HttpSession;
 import java.io.File;
 import java.io.IOException;
+import java.time.Duration;
 import java.util.*;
 
 /**
@@ -335,6 +336,7 @@ public class RedissonSessionManager extends ManagerBase {
                                 }
                                 RSet<String> set = getNotifiedNodes(msg.getSessionId());
                                 set.add(nodeId);
+                                set.expire(Duration.ofSeconds(60));
                             }
                             
                         }

redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSessionManager.java

@@ -34,6 +34,7 @@ import org.redisson.pubsub.PublishSubscribeService;
 import javax.servlet.http.HttpSession;
 import java.io.File;
 import java.io.IOException;
+import java.time.Duration;
 import java.util.*;
 
 /**
@@ -335,6 +336,7 @@ public class RedissonSessionManager extends ManagerBase {
                                 }
                                 RSet<String> set = getNotifiedNodes(msg.getSessionId());
                                 set.add(nodeId);
+                                set.expire(Duration.ofSeconds(60));
                             }
                             
                         }

redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java

@@ -34,6 +34,7 @@ import org.redisson.pubsub.PublishSubscribeService;
 import javax.servlet.http.HttpSession;
 import java.io.File;
 import java.io.IOException;
+import java.time.Duration;
 import java.util.*;
 
 /**
@@ -335,6 +336,7 @@ public class RedissonSessionManager extends ManagerBase {
                                 }
                                 RSet<String> set = getNotifiedNodes(msg.getSessionId());
                                 set.add(nodeId);
+                                set.expire(Duration.ofSeconds(60));
                             }
                             
                         }