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,LinkedMultiValueMap<java.lang.String,java.lang.String>> |
accessCache
Map from destination ->
|
private java.util.Map<java.lang.String,LinkedMultiValueMap<java.lang.String,java.lang.String>> |
updateCache
Map from destination ->
|
Modifier | Constructor and Description |
---|---|
private |
DestinationCache() |
Modifier and Type | Method and Description |
---|---|
void |
addSubscriptions(java.lang.String destination,
LinkedMultiValueMap<java.lang.String,java.lang.String> subscriptions) |
LinkedMultiValueMap<java.lang.String,java.lang.String> |
getSubscriptions(java.lang.String destination) |
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,LinkedMultiValueMap<java.lang.String,java.lang.String>> accessCache
private final java.util.Map<java.lang.String,LinkedMultiValueMap<java.lang.String,java.lang.String>> updateCache
public LinkedMultiValueMap<java.lang.String,java.lang.String> getSubscriptions(java.lang.String destination)
public void addSubscriptions(java.lang.String destination, LinkedMultiValueMap<java.lang.String,java.lang.String> subscriptions)
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)
public java.lang.String toString()
toString
in class java.lang.Object