org.springframework.messaging.simp

Class SimpAttributes

java.lang.Object

org.springframework.messaging.simp.SimpAttributes

public class SimpAttributes
extends java.lang.Object

A wrapper class for access to attributes associated with a SiMP session (e.g. WebSocket session).

Since:

4.1

Author:

Rossen Stoyanchev

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Map<java.lang.String,java.lang.Object>	attributes
static java.lang.String	DESTRUCTION_CALLBACK_NAME_PREFIX Prefix for the name of session attributes used to store destruction callbacks.
private static Log	logger
static java.lang.String	SESSION_COMPLETED_NAME Key set after the session is completed
static java.lang.String	SESSION_MUTEX_NAME Key for the mutex session attribute
private java.lang.String	sessionId

Constructor Summary

Constructors

Constructor and Description
SimpAttributes(java.lang.String sessionId, java.util.Map<java.lang.String,java.lang.Object> attributes) Constructor wrapping the given session attributes map.

Method Summary

Modifier and Type	Method and Description
private void	executeDestructionCallbacks()
static SimpAttributes	fromMessage(Message<?> message) Extract the SiMP session attributes from the given message and wrap them in a SimpAttributes instance.
java.lang.Object	getAttribute(java.lang.String name) Return the value for the attribute of the given name, if any.
java.lang.String[]	getAttributeNames() Retrieve the names of all attributes.
java.lang.String	getSessionId() Return an id for the associated session.
java.lang.Object	getSessionMutex() Expose the object to synchronize on for the underlying session.
boolean	isSessionCompleted() Whether the sessionCompleted() was already invoked.
void	registerDestructionCallback(java.lang.String name, java.lang.Runnable callback) Register a callback to execute on destruction of the specified attribute.
void	removeAttribute(java.lang.String name) Remove the attribute of the given name, if it exists.
private void	removeDestructionCallback(java.lang.String name)
void	sessionCompleted() Invoked when the session is completed.
void	setAttribute(java.lang.String name, java.lang.Object value) Set the value with the given name replacing an existing value (if any).

Methods inherited from class java.lang.Object

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

Field Detail

SESSION_MUTEX_NAME

public static final java.lang.String SESSION_MUTEX_NAME

Key for the mutex session attribute

SESSION_COMPLETED_NAME

public static final java.lang.String SESSION_COMPLETED_NAME

Key set after the session is completed

DESTRUCTION_CALLBACK_NAME_PREFIX

public static final java.lang.String DESTRUCTION_CALLBACK_NAME_PREFIX

Prefix for the name of session attributes used to store destruction callbacks.

logger

private static final Log logger

sessionId

private final java.lang.String sessionId

attributes

private final java.util.Map<java.lang.String,java.lang.Object> attributes

Constructor Detail

SimpAttributes

public SimpAttributes(java.lang.String sessionId,
                      java.util.Map<java.lang.String,java.lang.Object> attributes)

Constructor wrapping the given session attributes map.

Parameters:

sessionId - the id of the associated session

attributes - the attributes

Method Detail

getAttribute

public java.lang.Object getAttribute(java.lang.String name)

Return the value for the attribute of the given name, if any.

Parameters:

name - the name of the attribute

Returns:

the current attribute value, or null if not found

setAttribute

public void setAttribute(java.lang.String name,
                         java.lang.Object value)

Set the value with the given name replacing an existing value (if any).

Parameters:

name - the name of the attribute

value - the value for the attribute

removeAttribute

public void removeAttribute(java.lang.String name)

Remove the attribute of the given name, if it exists.

Also removes the registered destruction callback for the specified attribute, if any. However it does not execute the callback. It is assumed the removed object will continue to be used and destroyed independently at the appropriate time.

Parameters:

name - the name of the attribute

getAttributeNames

public java.lang.String[] getAttributeNames()

Retrieve the names of all attributes.

Returns:

the attribute names as String array, never null

registerDestructionCallback

public void registerDestructionCallback(java.lang.String name,
                                        java.lang.Runnable callback)

Register a callback to execute on destruction of the specified attribute. The callback is executed when the session is closed.

Parameters:

name - the name of the attribute to register the callback for

callback - the destruction callback to be executed

removeDestructionCallback

private void removeDestructionCallback(java.lang.String name)

getSessionId

public java.lang.String getSessionId()

Return an id for the associated session.

Returns:

the session id as String (never null)

getSessionMutex

public java.lang.Object getSessionMutex()

Expose the object to synchronize on for the underlying session.

Returns:

the session mutex to use (never null)

isSessionCompleted

public boolean isSessionCompleted()

Whether the sessionCompleted() was already invoked.

sessionCompleted

public void sessionCompleted()

Invoked when the session is completed. Executed completion callbacks.

executeDestructionCallbacks

private void executeDestructionCallbacks()

fromMessage

public static SimpAttributes fromMessage(Message<?> message)

Extract the SiMP session attributes from the given message and wrap them in a SimpAttributes instance.

Parameters:

message - the message to extract session attributes from