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 735f5c93d..5023c2245 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 @@ -135,7 +135,9 @@ public class RedissonSessionManager extends ManagerBase { } public RTopic getTopic() { - return redisson.getTopic("redisson:tomcat_session_updates:" + getContext().getName()); + String separator = keyPrefix == null || keyPrefix.isEmpty() ? "" : ":"; + final String name = keyPrefix + separator + "redisson:tomcat_session_updates:" + getContext().getName(); + return redisson.getTopic(name); } @Override