org.springframework.messaging.simp

Class SimpMessagingTemplate

java.lang.Object

org.springframework.messaging.core.AbstractMessageSendingTemplate<java.lang.String>

org.springframework.messaging.simp.SimpMessagingTemplate

All Implemented Interfaces:

MessageSendingOperations<java.lang.String>, SimpMessageSendingOperations

public class SimpMessagingTemplate
extends AbstractMessageSendingTemplate<java.lang.String>
implements SimpMessageSendingOperations

A specialization of AbstractMessageSendingTemplate that adds String-based destinations as a message header.

Since:

4.0

Author:

Mark Fisher

Field Summary

Fields

Modifier and Type	Field and Description
private MessageChannel	messageChannel
private long	sendTimeout
private java.lang.String	userDestinationPrefix

Fields inherited from class org.springframework.messaging.core.AbstractMessageSendingTemplate

logger

Constructor Summary

Constructors

Constructor and Description
SimpMessagingTemplate(MessageChannel messageChannel)

Method Summary

Modifier and Type	Method and Description
<T> void	convertAndSendToUser(java.lang.String user, java.lang.String destination, T message) Send a message to a specific user.
<T> void	convertAndSendToUser(java.lang.String user, java.lang.String destination, T message, MessagePostProcessor postProcessor) Send a message to a specific user.
protected void	doSend(java.lang.String destination, Message<?> message)
MessageChannel	getMessageChannel()
long	getSendTimeout()
java.lang.String	getUserDestinationPrefix()
<P> void	send(Message<P> message)
void	setSendTimeout(long sendTimeout) Specify the timeout value to use for send operations.
void	setUserDestinationPrefix(java.lang.String prefix) Configure the prefix to use for destinations targeting a specific user.

Methods inherited from class org.springframework.messaging.core.AbstractMessageSendingTemplate

convertAndSend, convertAndSend, convertAndSend, convertAndSend, getConverter, getDefaultDestination, getRequiredDefaultDestination, send, setConverter, setDefaultDestination, setMessageConverter

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.messaging.core.MessageSendingOperations

convertAndSend, convertAndSend, convertAndSend, convertAndSend, send

Field Detail

messageChannel

private final MessageChannel messageChannel

userDestinationPrefix

private java.lang.String userDestinationPrefix

sendTimeout

private volatile long sendTimeout

Constructor Detail

SimpMessagingTemplate

public SimpMessagingTemplate(MessageChannel messageChannel)

Method Detail

setUserDestinationPrefix

public void setUserDestinationPrefix(java.lang.String prefix)

Configure the prefix to use for destinations targeting a specific user.

The default value is "/user/".

See Also:

UserDestinationMessageHandler

getUserDestinationPrefix

public java.lang.String getUserDestinationPrefix()

Returns:

the userDestinationPrefix

getMessageChannel

public MessageChannel getMessageChannel()

Returns:

the messageChannel

setSendTimeout

public void setSendTimeout(long sendTimeout)

Specify the timeout value to use for send operations.

Parameters:

sendTimeout - the send timeout in milliseconds

getSendTimeout

public long getSendTimeout()

Returns:

the sendTimeout

send

public <P> void send(Message<P> message)

Specified by:

send in interface MessageSendingOperations<java.lang.String>

Overrides:

send in class AbstractMessageSendingTemplate<java.lang.String>

doSend

protected void doSend(java.lang.String destination,
          Message<?> message)

Specified by:

doSend in class AbstractMessageSendingTemplate<java.lang.String>

convertAndSendToUser

public <T> void convertAndSendToUser(java.lang.String user,
                            java.lang.String destination,
                            T message)
                          throws MessagingException

Description copied from interface: SimpMessageSendingOperations

Send a message to a specific user.

Specified by:

convertAndSendToUser in interface SimpMessageSendingOperations

Parameters:

user - the user that should receive the message.

destination - the destination to send the message to.

message - the message to send

Throws:

MessagingException

convertAndSendToUser

public <T> void convertAndSendToUser(java.lang.String user,
                            java.lang.String destination,
                            T message,
                            MessagePostProcessor postProcessor)
                          throws MessagingException

Description copied from interface: SimpMessageSendingOperations

Send a message to a specific user.

Specified by:

convertAndSendToUser in interface SimpMessageSendingOperations

Parameters:

user - the user that should receive the message.

destination - the destination to send the message to.

message - the message to send

postProcessor - a postProcessor to post-process or modify the created message

Throws:

MessagingException