public class DefaultSimpUserRegistry extends java.lang.Object implements SimpUserRegistry, SmartApplicationListener
SimpUserRegistry
that relies on
AbstractSubProtocolEvent
application context events to keep track of
connected users and their subscriptions.Modifier and Type | Class and Description |
---|---|
private static class |
DefaultSimpUserRegistry.LocalSimpSession |
private static class |
DefaultSimpUserRegistry.LocalSimpSubscription |
private static class |
DefaultSimpUserRegistry.LocalSimpUser |
Modifier and Type | Field and Description |
---|---|
private java.lang.Object |
sessionLock |
private java.util.Map<java.lang.String,DefaultSimpUserRegistry.LocalSimpSession> |
sessions |
private java.util.Map<java.lang.String,DefaultSimpUserRegistry.LocalSimpUser> |
users |
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
DefaultSimpUserRegistry() |
Modifier and Type | Method and Description |
---|---|
java.util.Set<SimpSubscription> |
findSubscriptions(SimpSubscriptionMatcher matcher)
Find subscriptions with the given matcher.
|
int |
getOrder()
Get the order value of this object.
|
SimpUser |
getUser(java.lang.String userName)
Get the user for the given name.
|
int |
getUserCount()
Return the count of all connected users.
|
java.util.Set<SimpUser> |
getUsers()
Return a snapshot of all connected users.
|
void |
onApplicationEvent(ApplicationEvent event)
Handle an application event.
|
boolean |
supportsEventType(java.lang.Class<? extends ApplicationEvent> eventType)
Determine whether this listener actually supports the given event type.
|
boolean |
supportsSourceType(java.lang.Class<?> sourceType)
Determine whether this listener actually supports the given source type.
|
java.lang.String |
toString() |
private final java.util.Map<java.lang.String,DefaultSimpUserRegistry.LocalSimpUser> users
private final java.util.Map<java.lang.String,DefaultSimpUserRegistry.LocalSimpSession> sessions
private final java.lang.Object sessionLock
public int getOrder()
Ordered
Higher values are interpreted as lower priority. As a consequence,
the object with the lowest value has the highest priority (somewhat
analogous to Servlet load-on-startup
values).
Same order values will result in arbitrary sort positions for the affected objects.
getOrder
in interface Ordered
Ordered.HIGHEST_PRECEDENCE
,
Ordered.LOWEST_PRECEDENCE
public boolean supportsEventType(java.lang.Class<? extends ApplicationEvent> eventType)
SmartApplicationListener
supportsEventType
in interface SmartApplicationListener
public void onApplicationEvent(ApplicationEvent event)
ApplicationListener
onApplicationEvent
in interface ApplicationListener<ApplicationEvent>
event
- the event to respond topublic boolean supportsSourceType(@Nullable java.lang.Class<?> sourceType)
SmartApplicationListener
supportsSourceType
in interface SmartApplicationListener
@Nullable public SimpUser getUser(java.lang.String userName)
SimpUserRegistry
getUser
in interface SimpUserRegistry
userName
- the name of the user to look upnull
if not connectedpublic java.util.Set<SimpUser> getUsers()
SimpUserRegistry
The returned set is a copy and will not reflect further changes.
getUsers
in interface SimpUserRegistry
public int getUserCount()
SimpUserRegistry
getUserCount
in interface SimpUserRegistry
public java.util.Set<SimpSubscription> findSubscriptions(SimpSubscriptionMatcher matcher)
SimpUserRegistry
findSubscriptions
in interface SimpUserRegistry
matcher
- the matcher to usepublic java.lang.String toString()
toString
in class java.lang.Object