public class DefaultSubscriptionRegistry extends AbstractSubscriptionRegistry
Modifier and Type | Class and Description |
---|---|
private static class |
DefaultSubscriptionRegistry.DestinationCache
Provide direct lookup of session subscriptions by destination (for non-pattern destinations).
|
private static class |
DefaultSubscriptionRegistry.SessionSubscriptionInfo
Hold subscriptions for a session.
|
private static class |
DefaultSubscriptionRegistry.SessionSubscriptionRegistry
Provide access to session subscriptions by sessionId.
|
Modifier and Type | Field and Description |
---|---|
private DefaultSubscriptionRegistry.DestinationCache |
destinationCache |
private AntPathMatcher |
pathMatcher |
private DefaultSubscriptionRegistry.SessionSubscriptionRegistry |
subscriptionRegistry |
logger
Constructor and Description |
---|
DefaultSubscriptionRegistry() |
Modifier and Type | Method and Description |
---|---|
protected void |
addSubscriptionInternal(java.lang.String sessionId,
java.lang.String subsId,
java.lang.String destination,
Message<?> message) |
protected MultiValueMap<java.lang.String,java.lang.String> |
findSubscriptionsInternal(java.lang.String destination,
Message<?> message) |
AntPathMatcher |
getPathMatcher() |
protected void |
removeSubscriptionInternal(java.lang.String sessionId,
java.lang.String subscriptionId,
Message<?> message) |
void |
setPathMatcher(AntPathMatcher pathMatcher) |
java.lang.String |
toString() |
void |
unregisterAllSubscriptions(java.lang.String sessionId)
Remove all subscriptions associated with the given sessionId.
|
findSubscriptions, registerSubscription, unregisterSubscription
private final DefaultSubscriptionRegistry.DestinationCache destinationCache
private final DefaultSubscriptionRegistry.SessionSubscriptionRegistry subscriptionRegistry
private AntPathMatcher pathMatcher
public void setPathMatcher(AntPathMatcher pathMatcher)
pathMatcher
- the pathMatcher to setpublic AntPathMatcher getPathMatcher()
protected void addSubscriptionInternal(java.lang.String sessionId, java.lang.String subsId, java.lang.String destination, Message<?> message)
addSubscriptionInternal
in class AbstractSubscriptionRegistry
protected void removeSubscriptionInternal(java.lang.String sessionId, java.lang.String subscriptionId, Message<?> message)
removeSubscriptionInternal
in class AbstractSubscriptionRegistry
public void unregisterAllSubscriptions(java.lang.String sessionId)
SubscriptionRegistry
unregisterAllSubscriptions
in interface SubscriptionRegistry
unregisterAllSubscriptions
in class AbstractSubscriptionRegistry
protected MultiValueMap<java.lang.String,java.lang.String> findSubscriptionsInternal(java.lang.String destination, Message<?> message)
findSubscriptionsInternal
in class AbstractSubscriptionRegistry
public java.lang.String toString()
toString
in class java.lang.Object