diff --git a/spring-session/src/main/java/org/springframework/session/web/socket/server/SessionRepositoryMessageInterceptor.java b/spring-session/src/main/java/org/springframework/session/web/socket/server/SessionRepositoryMessageInterceptor.java index a6cd44e..f36352f 100644 --- a/spring-session/src/main/java/org/springframework/session/web/socket/server/SessionRepositoryMessageInterceptor.java +++ b/spring-session/src/main/java/org/springframework/session/web/socket/server/SessionRepositoryMessageInterceptor.java @@ -124,6 +124,7 @@ public final class SessionRepositoryMessageInterceptor { + + @Override + public boolean matches(Object argument) { + long other = (Long) argument; + long now = System.currentTimeMillis(); + + long delta = now - other; + return delta >= 0 && delta < TimeUnit.SECONDS.toMillis(3); + } + + } }