NSL WebSocket/xyz.noisif.nsl.websocket/WsServer

WsServer

abstract class WsServer : IdempotentService

Inheritors

Constructors

protected constructor(builder: WsServer.AbstractBuilder<out Any>)

Types

AbstractBuilder

protected abstract class AbstractBuilder<B : WsServer.AbstractBuilder<B>?>

Properties

protected val authenticator: WsAuthenticator

authFailureHandler

protected val authFailureHandler: WsAuthFailureHandler

protected val broadcaster: WsBroadcaster

protected val busListener: RawBusListener<WsSession>

protected val idleTimeout: Duration

private val initialized: AtomicBoolean

lifecycleListener

protected val lifecycleListener: NetworkSessionLifecycleListener<WsSession>

localSessionDispatcher

protected val localSessionDispatcher: LocalSessionDispatcher

protected val log: Logger

protected val maxMessageSize: Long

protected val path: String

protected val port: Int

protected val rateLimiter: RateLimiter

private val running: AtomicBoolean

serializerRegistry

protected val serializerRegistry: EnvelopeSerializerRegistry

serializerResolver

protected val serializerResolver: WsSerializerResolver

sessionRegistry

protected val sessionRegistry: WsSessionRegistry

Functions

fun close()

determinateWsBroadcaster

private open fun determinateWsBroadcaster(builder: WsServer.AbstractBuilder<out Any>): WsBroadcaster

open fun getBroadcaster(): WsBroadcaster

abstract fun getLocalPort(): Int

getLocalSessionDispatcher

open fun getLocalSessionDispatcher(): LocalSessionDispatcher

getWsSubscriptionRegistry

open fun getWsSubscriptionRegistry(): WsSubscriptionRegistry

loadWsAuthenticators

private open fun loadWsAuthenticators(componentProvider: ComponentProvider, authenticators: List<WsAuthenticator>): WsAuthenticator

protected abstract fun onStart()

protected abstract fun onStop()

fun start()

translateException

protected open fun translateException(ex: Exception): RuntimeException