org.springframework.messaging.simp.handler

Class SimpleBrokerMessageHandler

java.lang.Object

org.springframework.messaging.simp.handler.SimpleBrokerMessageHandler

All Implemented Interfaces:

MessageHandler

public class SimpleBrokerMessageHandler
extends java.lang.Object
implements MessageHandler

Since:

4.0

Author:

Rossen Stoyanchev

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.List<java.lang.String>	destinationPrefixes
private static Log	logger
private MessageChannel	messageChannel
private SubscriptionRegistry	subscriptionRegistry

Constructor Summary

Constructors

Constructor and Description
SimpleBrokerMessageHandler(MessageChannel messageChannel)

Method Summary

Modifier and Type	Method and Description
private boolean	checkDestinationPrefix(java.lang.String destination)
java.util.List<java.lang.String>	getDestinationPrefixes()
SubscriptionRegistry	getSubscriptionRegistry()
void	handleMessage(Message<?> message) Handles the message if possible.
private void	preProcessMessage(Message<?> message)
protected void	sendMessageToSubscribers(java.lang.String destination, Message<?> message)
void	setDestinationPrefixes(java.util.List<java.lang.String> destinationPrefixes)
void	setSubscriptionRegistry(SubscriptionRegistry subscriptionRegistry)

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final Log logger

messageChannel

private final MessageChannel messageChannel

destinationPrefixes

private java.util.List<java.lang.String> destinationPrefixes

subscriptionRegistry

private SubscriptionRegistry subscriptionRegistry

Constructor Detail

SimpleBrokerMessageHandler

public SimpleBrokerMessageHandler(MessageChannel messageChannel)

Parameters:

messageChannel - the channel to broadcast messages to

Method Detail

setDestinationPrefixes

public void setDestinationPrefixes(java.util.List<java.lang.String> destinationPrefixes)

getDestinationPrefixes

public java.util.List<java.lang.String> getDestinationPrefixes()

setSubscriptionRegistry

public void setSubscriptionRegistry(SubscriptionRegistry subscriptionRegistry)

getSubscriptionRegistry

public SubscriptionRegistry getSubscriptionRegistry()

handleMessage

public void handleMessage(Message<?> message)
                   throws MessagingException

Description copied from interface: MessageHandler

Handles the message if possible. If the handler cannot deal with the message this will result in a MessageRejectedException e.g. in case of a Selective Consumer. When a consumer tries to handle a message, but fails to do so, a MessageHandlingException is thrown. In the last case it is recommended to treat the message as tainted and go into an error scenario.

When the handling results in a failure of another message being sent (e.g. a "reply" message), that failure will trigger a MessageDeliveryException.

Specified by:

handleMessage in interface MessageHandler

Parameters:

message - the message to be handled reply related to the handling of the message

Throws:

MessagingException

checkDestinationPrefix

private boolean checkDestinationPrefix(java.lang.String destination)

preProcessMessage

private void preProcessMessage(Message<?> message)

sendMessageToSubscribers

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