org.springframework.messaging.simp.broker

Class DefaultSubscriptionRegistry.SessionSubscriptionRegistry

java.lang.Object

org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry.SessionSubscriptionRegistry

Enclosing class:

DefaultSubscriptionRegistry

private static class DefaultSubscriptionRegistry.SessionSubscriptionRegistry
extends java.lang.Object

Provide access to session subscriptions by sessionId.

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.ConcurrentMap<java.lang.String,DefaultSubscriptionRegistry.SessionSubscriptionInfo>	sessions

Constructor Summary

Constructors

Modifier	Constructor and Description
private	SessionSubscriptionRegistry()

Method Summary

Modifier and Type	Method and Description
DefaultSubscriptionRegistry.SessionSubscriptionInfo	addSubscription(java.lang.String sessionId, java.lang.String subscriptionId, java.lang.String destination, Expression selectorExpression)
java.util.Collection<DefaultSubscriptionRegistry.SessionSubscriptionInfo>	getAllSubscriptions()
DefaultSubscriptionRegistry.SessionSubscriptionInfo	getSubscriptions(java.lang.String sessionId)
DefaultSubscriptionRegistry.SessionSubscriptionInfo	removeSubscriptions(java.lang.String sessionId)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

sessions

private final java.util.concurrent.ConcurrentMap<java.lang.String,DefaultSubscriptionRegistry.SessionSubscriptionInfo> sessions

Constructor Detail

SessionSubscriptionRegistry

private SessionSubscriptionRegistry()

Method Detail

getSubscriptions

public DefaultSubscriptionRegistry.SessionSubscriptionInfo getSubscriptions(java.lang.String sessionId)

getAllSubscriptions

public java.util.Collection<DefaultSubscriptionRegistry.SessionSubscriptionInfo> getAllSubscriptions()

addSubscription

public DefaultSubscriptionRegistry.SessionSubscriptionInfo addSubscription(java.lang.String sessionId,
                                                                           java.lang.String subscriptionId,
                                                                           java.lang.String destination,
                                                                           Expression selectorExpression)

removeSubscriptions

public DefaultSubscriptionRegistry.SessionSubscriptionInfo removeSubscriptions(java.lang.String sessionId)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object