From 19b8583d65d6cce61121d2f7c912b46d26d35a1f Mon Sep 17 00:00:00 2001 From: Vedran Pavic Date: Wed, 13 Jun 2018 05:59:50 +0200 Subject: [PATCH] Adapt to Spring Framework deprecations See gh-1092 --- .../server/SessionRepositoryMessageInterceptor.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) 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