private class DefaultSubscriptionRegistry.DestinationCache
extends java.lang.Object
DefaultSubscriptionRegistry.findSubscriptionsInternal(String, Message)
Modifier and Type | Field and Description |
---|---|
private java.util.Map<java.lang.String,MultiValueMap<java.lang.String,java.lang.String>> |
accessCache
Map from destination ->
|
private java.util.Map<java.lang.String,MultiValueMap<java.lang.String,java.lang.String>> |
updateCache
Map from destination ->
|
Modifier | Constructor and Description |
---|---|
private |
DestinationCache() |
Modifier and Type | Method and Description |
---|---|
private <K,V> LinkedMultiValueMap<K,V> |
deepCopy(java.util.Map<K,java.util.List<V>> map) |
MultiValueMap<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) |
private final java.util.Map<java.lang.String,MultiValueMap<java.lang.String,java.lang.String>> accessCache
private final java.util.Map<java.lang.String,MultiValueMap<java.lang.String,java.lang.String>> updateCache
public MultiValueMap<java.lang.String,java.lang.String> getSubscriptions(java.lang.String destination, Message<?> message)
public void updateAfterNewSubscription(java.lang.String destination, java.lang.String sessionId, java.lang.String subsId)
public void updateAfterRemovedSubscription(java.lang.String sessionId, java.lang.String subsId)
public void updateAfterRemovedSession(DefaultSubscriptionRegistry.SessionSubscriptionInfo info)
private <K,V> LinkedMultiValueMap<K,V> deepCopy(java.util.Map<K,java.util.List<V>> map)
public java.lang.String toString()
toString
in class java.lang.Object