org.springframework.messaging.simp.broker

Class DefaultSubscriptionRegistry.DestinationCache

java.lang.Object

org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry.DestinationCache

Enclosing class:

DefaultSubscriptionRegistry

private class DefaultSubscriptionRegistry.DestinationCache
extends java.lang.Object

A cache for destinations previously resolved via DefaultSubscriptionRegistry.findSubscriptionsInternal(String, Message)

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Map<java.lang.String,LinkedMultiValueMap<java.lang.String,java.lang.String>>	accessCache Map from destination -> for fast look-ups
private java.util.Map<java.lang.String,LinkedMultiValueMap<java.lang.String,java.lang.String>>	updateCache Map from destination -> with locking

Constructor Summary

Constructors

Modifier	Constructor and Description
private	DestinationCache()

Method Summary

Modifier and Type	Method and Description
LinkedMultiValueMap<java.lang.String,java.lang.String>	getSubscriptions(java.lang.String destination, Message<?> message)
java.lang.String	toString()
void	updateAfterNewSubscription(java.lang.String destination, java.lang.String sessionId, java.lang.String subsId)
void	updateAfterRemovedSession(DefaultSubscriptionRegistry.SessionSubscriptionInfo info)
void	updateAfterRemovedSubscription(java.lang.String sessionId, java.lang.String subsId)

Methods inherited from class java.lang.Object

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

Field Detail

accessCache

private final java.util.Map<java.lang.String,LinkedMultiValueMap<java.lang.String,java.lang.String>> accessCache

Map from destination -> for fast look-ups

updateCache

private final java.util.Map<java.lang.String,LinkedMultiValueMap<java.lang.String,java.lang.String>> updateCache

Map from destination -> with locking

Constructor Detail

DestinationCache

private DestinationCache()

Method Detail

getSubscriptions

public LinkedMultiValueMap<java.lang.String,java.lang.String> getSubscriptions(java.lang.String destination,
                                                                               Message<?> message)

updateAfterNewSubscription

public void updateAfterNewSubscription(java.lang.String destination,
                                       java.lang.String sessionId,
                                       java.lang.String subsId)

updateAfterRemovedSubscription

public void updateAfterRemovedSubscription(java.lang.String sessionId,
                                           java.lang.String subsId)

updateAfterRemovedSession

public void updateAfterRemovedSession(DefaultSubscriptionRegistry.SessionSubscriptionInfo info)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object