org.springframework.messaging.simp

Class SimpMessageHeaderAccessor

java.lang.Object

org.springframework.messaging.support.MessageHeaderAccessor

org.springframework.messaging.support.NativeMessageHeaderAccessor

org.springframework.messaging.simp.SimpMessageHeaderAccessor

Direct Known Subclasses:

StompHeaderAccessor

public class SimpMessageHeaderAccessor
extends NativeMessageHeaderAccessor

A base class for working with message headers in simple messaging protocols that support basic messaging patterns. Provides uniform access to specific values common across protocols such as a destination, message type (e.g. publish, subscribe, etc), session id, and others.

Use one of the static factory method in this class, then call getters and setters, and at the end if necessary call MessageHeaderAccessor.toMap() to obtain the updated headers.

Since:

4.0

Author:

Rossen Stoyanchev

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CONNECT_MESSAGE_HEADER
static java.lang.String	DESTINATION_HEADER
private static IdTimestampMessageHeaderInitializer	headerInitializer
static java.lang.String	HEART_BEAT_HEADER
static java.lang.String	IGNORE_ERROR A header that indicates to the broker that the sender will ignore errors.
static java.lang.String	MESSAGE_TYPE_HEADER
static java.lang.String	ORIGINAL_DESTINATION A header for internal use with "user" destinations where we need to restore the destination prior to sending messages to clients.
static java.lang.String	SESSION_ATTRIBUTES
static java.lang.String	SESSION_ID_HEADER
static java.lang.String	SUBSCRIPTION_ID_HEADER
static java.lang.String	USER_HEADER

Fields inherited from class org.springframework.messaging.support.NativeMessageHeaderAccessor

NATIVE_HEADERS

Fields inherited from class org.springframework.messaging.support.MessageHeaderAccessor

DEFAULT_CHARSET, logger

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SimpMessageHeaderAccessor(Message<?> message) A constructor for accessing and modifying existing message headers.
protected	SimpMessageHeaderAccessor(SimpMessageType messageType, java.util.Map<java.lang.String,java.util.List<java.lang.String>> externalSourceHeaders) A constructor for creating new message headers.

Method Summary

Modifier and Type	Method and Description
static SimpMessageHeaderAccessor	create() Create an instance with SimpMessageType MESSAGE.
static SimpMessageHeaderAccessor	create(SimpMessageType messageType) Create an instance with the given SimpMessageType.
protected MessageHeaderAccessor	createAccessor(Message<?> message) Build a 'nested' accessor for the given message.
private java.lang.StringBuilder	getBaseLogMessage()
java.lang.String	getDestination()
static java.lang.String	getDestination(java.util.Map<java.lang.String,java.lang.Object> headers)
java.lang.String	getDetailedLogMessage(java.lang.Object payload) Return a more detailed message for logging purposes.
static long[]	getHeartbeat(java.util.Map<java.lang.String,java.lang.Object> headers)
SimpMessageType	getMessageType()
static SimpMessageType	getMessageType(java.util.Map<java.lang.String,java.lang.Object> headers)
java.util.Map<java.lang.String,java.lang.Object>	getSessionAttributes() Return the attributes associated with the current session.
static java.util.Map<java.lang.String,java.lang.Object>	getSessionAttributes(java.util.Map<java.lang.String,java.lang.Object> headers)
java.lang.String	getSessionId()
static java.lang.String	getSessionId(java.util.Map<java.lang.String,java.lang.Object> headers)
java.lang.String	getShortLogMessage(java.lang.Object payload) Return a concise message for logging purposes.
java.lang.String	getSubscriptionId()
static java.lang.String	getSubscriptionId(java.util.Map<java.lang.String,java.lang.Object> headers)
java.security.Principal	getUser() Return the user associated with the current session.
static java.security.Principal	getUser(java.util.Map<java.lang.String,java.lang.Object> headers)
void	setDestination(java.lang.String destination)
void	setMessageTypeIfNotSet(SimpMessageType messageType)
void	setSessionAttributes(java.util.Map<java.lang.String,java.lang.Object> attributes) A static alternative for access to the session attributes header.
void	setSessionId(java.lang.String sessionId)
void	setSubscriptionId(java.lang.String subscriptionId)
void	setUser(java.security.Principal principal)
static SimpMessageHeaderAccessor	wrap(Message<?> message) Create an instance from the payload and headers of the given Message.

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

addNativeHeader, addNativeHeaders, containsNativeHeader, getFirstNativeHeader, getFirstNativeHeader, getNativeHeader, removeNativeHeader, setImmutable, setNativeHeader, toNativeHeaderMap

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

copyHeaders, copyHeadersIfAbsent, getAccessor, getAccessor, getContentType, getDetailedPayloadLogMessage, getErrorChannel, getHeader, getId, getMessageHeaders, getMutableAccessor, getReplyChannel, getShortPayloadLogMessage, getTimestamp, isModified, isMutable, isReadableContentType, isReadOnly, removeHeader, removeHeaders, setContentType, setErrorChannel, setErrorChannelName, setHeader, setHeaderIfAbsent, setLeaveMutable, setModified, setReplyChannel, setReplyChannelName, toMap, toMessageHeaders, toString, verifyType

Methods inherited from class java.lang.Object

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

Field Detail

headerInitializer

private static final IdTimestampMessageHeaderInitializer headerInitializer

DESTINATION_HEADER

public static final java.lang.String DESTINATION_HEADER

See Also:

Constant Field Values

MESSAGE_TYPE_HEADER

public static final java.lang.String MESSAGE_TYPE_HEADER

See Also:

Constant Field Values

SESSION_ID_HEADER

public static final java.lang.String SESSION_ID_HEADER

See Also:

Constant Field Values

SESSION_ATTRIBUTES

public static final java.lang.String SESSION_ATTRIBUTES

See Also:

Constant Field Values

SUBSCRIPTION_ID_HEADER

public static final java.lang.String SUBSCRIPTION_ID_HEADER

See Also:

Constant Field Values

USER_HEADER

public static final java.lang.String USER_HEADER

See Also:

Constant Field Values

CONNECT_MESSAGE_HEADER

public static final java.lang.String CONNECT_MESSAGE_HEADER

See Also:

Constant Field Values

HEART_BEAT_HEADER

public static final java.lang.String HEART_BEAT_HEADER

See Also:

Constant Field Values

ORIGINAL_DESTINATION

public static final java.lang.String ORIGINAL_DESTINATION

A header for internal use with "user" destinations where we need to restore the destination prior to sending messages to clients.

See Also:

Constant Field Values

IGNORE_ERROR

public static final java.lang.String IGNORE_ERROR

A header that indicates to the broker that the sender will ignore errors. The header is simply checked for presence or absence.

See Also:

Constant Field Values

Constructor Detail

SimpMessageHeaderAccessor

protected SimpMessageHeaderAccessor(SimpMessageType messageType,
                                    java.util.Map<java.lang.String,java.util.List<java.lang.String>> externalSourceHeaders)

A constructor for creating new message headers. This constructor is protected. See factory methods in this and sub-classes.

SimpMessageHeaderAccessor

protected SimpMessageHeaderAccessor(Message<?> message)

A constructor for accessing and modifying existing message headers. This constructor is protected. See factory methods in this and sub-classes.

Method Detail

createAccessor

protected MessageHeaderAccessor createAccessor(Message<?> message)

Description copied from class: MessageHeaderAccessor

Build a 'nested' accessor for the given message.

Overrides:

createAccessor in class MessageHeaderAccessor

Parameters:

message - the message to build a new accessor for

Returns:

the nested accessor (typically a specific subclass)

setMessageTypeIfNotSet

public void setMessageTypeIfNotSet(SimpMessageType messageType)

getMessageType

public SimpMessageType getMessageType()

setDestination

public void setDestination(java.lang.String destination)

getDestination

public java.lang.String getDestination()

setSubscriptionId

public void setSubscriptionId(java.lang.String subscriptionId)

getSubscriptionId

public java.lang.String getSubscriptionId()

setSessionId

public void setSessionId(java.lang.String sessionId)

getSessionId

public java.lang.String getSessionId()

Returns:

the id of the current session

setSessionAttributes

public void setSessionAttributes(java.util.Map<java.lang.String,java.lang.Object> attributes)

A static alternative for access to the session attributes header.

getSessionAttributes

public java.util.Map<java.lang.String,java.lang.Object> getSessionAttributes()

Return the attributes associated with the current session.

setUser

public void setUser(java.security.Principal principal)

getUser

public java.security.Principal getUser()

Return the user associated with the current session.

getShortLogMessage

public java.lang.String getShortLogMessage(java.lang.Object payload)

Description copied from class: MessageHeaderAccessor

Return a concise message for logging purposes.

Overrides:

getShortLogMessage in class MessageHeaderAccessor

Parameters:

payload - the payload that corresponds to the headers.

Returns:

the message

getDetailedLogMessage

public java.lang.String getDetailedLogMessage(java.lang.Object payload)

Description copied from class: MessageHeaderAccessor

Return a more detailed message for logging purposes.

Overrides:

getDetailedLogMessage in class MessageHeaderAccessor

Parameters:

payload - the payload that corresponds to the headers.

Returns:

the message

getBaseLogMessage

private java.lang.StringBuilder getBaseLogMessage()

create

public static SimpMessageHeaderAccessor create()

Create an instance with SimpMessageType MESSAGE.

create

public static SimpMessageHeaderAccessor create(SimpMessageType messageType)

Create an instance with the given SimpMessageType.

wrap

public static SimpMessageHeaderAccessor wrap(Message<?> message)

Create an instance from the payload and headers of the given Message.

getMessageType

public static SimpMessageType getMessageType(java.util.Map<java.lang.String,java.lang.Object> headers)

getDestination

public static java.lang.String getDestination(java.util.Map<java.lang.String,java.lang.Object> headers)

getSubscriptionId

public static java.lang.String getSubscriptionId(java.util.Map<java.lang.String,java.lang.Object> headers)

getSessionId

public static java.lang.String getSessionId(java.util.Map<java.lang.String,java.lang.Object> headers)

getSessionAttributes

public static java.util.Map<java.lang.String,java.lang.Object> getSessionAttributes(java.util.Map<java.lang.String,java.lang.Object> headers)

getUser

public static java.security.Principal getUser(java.util.Map<java.lang.String,java.lang.Object> headers)

getHeartbeat

public static long[] getHeartbeat(java.util.Map<java.lang.String,java.lang.Object> headers)