org.springframework.session.web.socket.server

Class SessionRepositoryMessageInterceptor<S extends ExpiringSession>

java.lang.Object

org.springframework.messaging.support.ChannelInterceptorAdapter

org.springframework.session.web.socket.server.SessionRepositoryMessageInterceptor<S>

Type Parameters:

S - the ExpiringSession type

All Implemented Interfaces:

org.springframework.messaging.support.ChannelInterceptor, org.springframework.web.socket.server.HandshakeInterceptor

public final class SessionRepositoryMessageInterceptor<S extends ExpiringSession>
extends org.springframework.messaging.support.ChannelInterceptorAdapter
implements org.springframework.web.socket.server.HandshakeInterceptor

Acts as a ChannelInterceptor and a HandshakeInterceptor to ensure the ExpiringSession.getLastAccessedTime() is up to date.

• Associates the Session.getId() with the WebSocket Session attributes when the handshake is performed. This is later used when intercepting messages to ensure the ExpiringSession.getLastAccessedTime() is updated.
• Intercepts Message's that are have SimpMessageType that corresponds to setMatchingMessageTypes(Set) and updates the last accessed time of the Session. If the Session is expired, the Message is prevented from proceeding.

In order to work SessionRepositoryMessageInterceptor must be registered as a ChannelInterceptor and a HandshakeInterceptor .

Since:

1.0

Author:

Rob Winch

Constructor Summary

Constructors

Constructor and Description
SessionRepositoryMessageInterceptor(SessionRepository<S> sessionRepository) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	afterHandshake(org.springframework.http.server.ServerHttpRequest request, org.springframework.http.server.ServerHttpResponse response, org.springframework.web.socket.WebSocketHandler wsHandler, Exception exception)
boolean	beforeHandshake(org.springframework.http.server.ServerHttpRequest request, org.springframework.http.server.ServerHttpResponse response, org.springframework.web.socket.WebSocketHandler wsHandler, Map<String,Object> attributes)
static String	getSessionId(Map<String,Object> attributes)
org.springframework.messaging.Message<?>	preSend(org.springframework.messaging.Message<?> message, org.springframework.messaging.MessageChannel channel)
void	setMatchingMessageTypes(Set<org.springframework.messaging.simp.SimpMessageType> matchingMessageTypes) Sets the SimpMessageType to match on.
static void	setSessionId(Map<String,Object> attributes, String sessionId)

Methods inherited from class org.springframework.messaging.support.ChannelInterceptorAdapter

afterReceiveCompletion, afterSendCompletion, postReceive, postSend, preReceive

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SessionRepositoryMessageInterceptor

public SessionRepositoryMessageInterceptor(SessionRepository<S> sessionRepository)

Creates a new instance.

Parameters:

sessionRepository - the SessionRepository to use. Cannot be null.

Method Detail

setMatchingMessageTypes

public void setMatchingMessageTypes(Set<org.springframework.messaging.simp.SimpMessageType> matchingMessageTypes)

Sets the SimpMessageType to match on. If the Message matches, then preSend(Message, MessageChannel) ensures the Session is not expired and updates the ExpiringSession.getLastAccessedTime()

The default is: SimpMessageType.CONNECT, SimpMessageType.MESSAGE, SimpMessageType.SUBSCRIBE, SimpMessageType.UNSUBSCRIBE.

Parameters:

matchingMessageTypes - the SimpMessageType to match on in preSend(Message, MessageChannel), else the Message is continued without accessing or updating the Session

preSend

public org.springframework.messaging.Message<?> preSend(org.springframework.messaging.Message<?> message,
                                                        org.springframework.messaging.MessageChannel channel)

Specified by:

preSend in interface org.springframework.messaging.support.ChannelInterceptor

Overrides:

preSend in class org.springframework.messaging.support.ChannelInterceptorAdapter

beforeHandshake

public boolean beforeHandshake(org.springframework.http.server.ServerHttpRequest request,
                               org.springframework.http.server.ServerHttpResponse response,
                               org.springframework.web.socket.WebSocketHandler wsHandler,
                               Map<String,Object> attributes)
                        throws Exception

Specified by:

beforeHandshake in interface org.springframework.web.socket.server.HandshakeInterceptor

Throws:

Exception

afterHandshake

public void afterHandshake(org.springframework.http.server.ServerHttpRequest request,
                           org.springframework.http.server.ServerHttpResponse response,
                           org.springframework.web.socket.WebSocketHandler wsHandler,
                           Exception exception)

Specified by:

afterHandshake in interface org.springframework.web.socket.server.HandshakeInterceptor

getSessionId

public static String getSessionId(Map<String,Object> attributes)

setSessionId

public static void setSessionId(Map<String,Object> attributes,
                                String sessionId)