org.springframework.messaging.simp.user

Class UserRegistryMessageHandler

java.lang.Object

org.springframework.messaging.simp.user.UserRegistryMessageHandler

All Implemented Interfaces:

EventListener, ApplicationListener<BrokerAvailabilityEvent>, MessageHandler

public class UserRegistryMessageHandler
extends Object
implements MessageHandler, ApplicationListener<BrokerAvailabilityEvent>

A MessageHandler that is subscribed to listen to broadcasts of user registry information from other application servers as well as to periodically broadcast the content of the local user registry. The aggregated information is maintained in a MultiServerUserRegistry.

Since:

4.2

Author:

Rossen Stoyanchev

Constructor Summary

Constructors

Constructor and Description
UserRegistryMessageHandler(SimpUserRegistry userRegistry, SimpMessagingTemplate brokerTemplate, String broadcastDestination, TaskScheduler scheduler)

Method Summary

Modifier and Type	Method and Description
String	getBroadcastDestination() Return the destination for broadcasting user registry information to.
long	getRegistryExpirationPeriod() Return the configured registry expiration period.
void	handleMessage(Message<?> message) Handle the given message.
void	onApplicationEvent(BrokerAvailabilityEvent event) Handle an application event.
void	setRegistryExpirationPeriod(long expirationPeriod) Configure how long before a remote registry snapshot expires.

Methods inherited from class java.lang.Object

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

Constructor Detail

UserRegistryMessageHandler

public UserRegistryMessageHandler(SimpUserRegistry userRegistry,
                                  SimpMessagingTemplate brokerTemplate,
                                  String broadcastDestination,
                                  TaskScheduler scheduler)

Method Detail

getBroadcastDestination

public String getBroadcastDestination()

Return the destination for broadcasting user registry information to.

setRegistryExpirationPeriod

public void setRegistryExpirationPeriod(long expirationPeriod)

Configure how long before a remote registry snapshot expires.

By default this is set to 20000 (20 seconds).

Parameters:

expirationPeriod - the expiration period in milliseconds

getRegistryExpirationPeriod

public long getRegistryExpirationPeriod()

Return the configured registry expiration period.

onApplicationEvent

public void onApplicationEvent(BrokerAvailabilityEvent event)

Description copied from interface: ApplicationListener

Handle an application event.

Specified by:

onApplicationEvent in interface ApplicationListener<BrokerAvailabilityEvent>

Parameters:

event - the event to respond to

handleMessage

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

Description copied from interface: MessageHandler

Handle the given message.

Specified by:

handleMessage in interface MessageHandler

Parameters:

message - the message to be handled

Throws:

MessagingException