org.springframework.web.socket.messaging

Class StompSubProtocolHandler

java.lang.Object

org.springframework.web.socket.messaging.StompSubProtocolHandler

All Implemented Interfaces:

SubProtocolHandler

public class StompSubProtocolHandler
extends Object
implements SubProtocolHandler

A SubProtocolHandler for STOMP that supports versions 1.0, 1.1, and 1.2 of the STOMP specification.

Since:

4.0

Author:

Rossen Stoyanchev, Andy Wilkinson

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONNECTED_USER_HEADER The name of the header set on the CONNECTED frame indicating the name of the user authenticated on the WebSocket session.

Constructor Summary

Constructors

Constructor and Description
StompSubProtocolHandler()

Method Summary

Modifier and Type	Method and Description
void	afterSessionEnded(WebSocketSession session, CloseStatus closeStatus, MessageChannel outputChannel) Invoked after a WebSocketSession has ended.
void	afterSessionStarted(WebSocketSession session, MessageChannel outputChannel) Invoked after a WebSocketSession has started.
List<String>	getSupportedProtocols() Return the list of sub-protocols supported by this handler, never null.
UserSessionRegistry	getUserSessionRegistry()
void	handleMessageFromClient(WebSocketSession session, WebSocketMessage<?> webSocketMessage, MessageChannel outputChannel) Handle incoming WebSocket messages from clients.
void	handleMessageToClient(WebSocketSession session, Message<?> message) Handle STOMP messages going back out to WebSocket clients.
String	resolveSessionId(Message<?> message) Resolve the session id from the given message or return null.
protected void	sendErrorMessage(WebSocketSession session, Throwable error)
void	setUserSessionRegistry(UserSessionRegistry registry) Provide a registry with which to register active user session ids.

Methods inherited from class java.lang.Object

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

Field Detail

CONNECTED_USER_HEADER

public static final String CONNECTED_USER_HEADER

The name of the header set on the CONNECTED frame indicating the name of the user authenticated on the WebSocket session.

See Also:

Constant Field Values

Constructor Detail

StompSubProtocolHandler

public StompSubProtocolHandler()

Method Detail

setUserSessionRegistry

public void setUserSessionRegistry(UserSessionRegistry registry)

Provide a registry with which to register active user session ids.

See Also:

UserDestinationMessageHandler

getUserSessionRegistry

public UserSessionRegistry getUserSessionRegistry()

Returns:

the configured UserSessionRegistry.

getSupportedProtocols

public List<String> getSupportedProtocols()

Description copied from interface: SubProtocolHandler

Return the list of sub-protocols supported by this handler, never null.

Specified by:

getSupportedProtocols in interface SubProtocolHandler

handleMessageFromClient

public void handleMessageFromClient(WebSocketSession session,
                                    WebSocketMessage<?> webSocketMessage,
                                    MessageChannel outputChannel)

Handle incoming WebSocket messages from clients.

Specified by:

handleMessageFromClient in interface SubProtocolHandler

Parameters:

session - the client session

webSocketMessage - the client message

outputChannel - an output channel to send messages to

sendErrorMessage

protected void sendErrorMessage(WebSocketSession session,
                                Throwable error)

handleMessageToClient

public void handleMessageToClient(WebSocketSession session,
                                  Message<?> message)

Handle STOMP messages going back out to WebSocket clients.

Specified by:

handleMessageToClient in interface SubProtocolHandler

Parameters:

session - the client session

message - the client message

resolveSessionId

public String resolveSessionId(Message<?> message)

Description copied from interface: SubProtocolHandler

Resolve the session id from the given message or return null.

Specified by:

resolveSessionId in interface SubProtocolHandler

Parameters:

message - the message to resolve the session id from

afterSessionStarted

public void afterSessionStarted(WebSocketSession session,
                                MessageChannel outputChannel)

Description copied from interface: SubProtocolHandler

Invoked after a WebSocketSession has started.

Specified by:

afterSessionStarted in interface SubProtocolHandler

Parameters:

session - the client session

outputChannel - a channel

afterSessionEnded

public void afterSessionEnded(WebSocketSession session,
                              CloseStatus closeStatus,
                              MessageChannel outputChannel)

Description copied from interface: SubProtocolHandler

Invoked after a WebSocketSession has ended.

Specified by:

afterSessionEnded in interface SubProtocolHandler

Parameters:

session - the client session

closeStatus - the reason why the session was closed

outputChannel - a channel