diff --git a/spring-session-core/src/main/java/org/springframework/session/web/socket/server/SessionRepositoryMessageInterceptor.java b/spring-session-core/src/main/java/org/springframework/session/web/socket/server/SessionRepositoryMessageInterceptor.java index 15062972..3475bfac 100644 --- a/spring-session-core/src/main/java/org/springframework/session/web/socket/server/SessionRepositoryMessageInterceptor.java +++ b/spring-session-core/src/main/java/org/springframework/session/web/socket/server/SessionRepositoryMessageInterceptor.java @@ -1,5 +1,5 @@ /* - * Copyright 2014-2017 the original author or authors. + * Copyright 2014-2018 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -31,7 +31,6 @@ import org.springframework.messaging.MessageChannel; import org.springframework.messaging.simp.SimpMessageHeaderAccessor; import org.springframework.messaging.simp.SimpMessageType; import org.springframework.messaging.support.ChannelInterceptor; -import org.springframework.messaging.support.ChannelInterceptorAdapter; import org.springframework.session.Session; import org.springframework.session.SessionRepository; import org.springframework.util.Assert; @@ -63,7 +62,7 @@ import org.springframework.web.socket.server.HandshakeInterceptor; * @since 1.0 */ public final class SessionRepositoryMessageInterceptor - extends ChannelInterceptorAdapter implements HandshakeInterceptor { + implements ChannelInterceptor, HandshakeInterceptor { private static final String SPRING_SESSION_ID_ATTR_NAME = "SPRING.SESSION.ID"; @@ -114,7 +113,7 @@ public final class SessionRepositoryMessageInterceptor SimpMessageType messageType = SimpMessageHeaderAccessor .getMessageType(message.getHeaders()); if (!this.matchingMessageTypes.contains(messageType)) { - return super.preSend(message, channel); + return message; } Map sessionHeaders = SimpMessageHeaderAccessor .getSessionAttributes(message.getHeaders()); @@ -128,7 +127,7 @@ public final class SessionRepositoryMessageInterceptor this.sessionRepository.save(session); } } - return super.preSend(message, channel); + return message; } @Override