NSL WebSocket/xyz.noisif.nsl.websocket.registry/InMemoryWsSessionRegistry

InMemoryWsSessionRegistry

open class InMemoryWsSessionRegistry : GenericConcurrentRegistry<String, WsSession> , WsSessionRegistry

Constructors

InMemoryWsSessionRegistry

private constructor()

Properties

private val allowOverwrite: Boolean

protected val log: Logger

private val registry: Map<K, V>

private val sessionTopics: Map<String, Set<String>>

private val subscriptions: Map<String, Map<String, WsSession>>

Functions

open fun clear()

open fun createDefault(): InMemoryWsSessionRegistry

open fun get(key: K): V

open fun getAll(): Collection<V>

open fun getAllSessions(): Collection<WsSession>

open fun getEntries(): Map<K, V>

open fun getOrNull(key: K): V

open fun getSubscribers(topic: WsTopic): Collection<WsSession>

getUnsafeSubscribers

open fun getUnsafeSubscribers(topic: String): Collection<WsSession>

protected open fun putDirect(key: K, value: V): V

open fun register(key: K, value: V)

open fun register(session: WsSession)

open fun remove(key: K): Boolean

open fun removeDirect(key: K, value: V): Boolean

open fun subscribe(session: WsSession, topic: WsTopic)

open fun unregister(session: WsSession)

open fun unsubscribe(session: WsSession, topic: WsTopic)