NSL WebSocket/xyz.noisif.nsl.websocket.jetty/JettyWsServer

JettyWsServer

open class JettyWsServer : WsServer

Constructors

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

Types

open class Builder : WsServer.AbstractBuilder<JettyWsServer.Builder>

Properties

protected val authenticator: WsAuthenticator

authFailureHandler

protected val authFailureHandler: WsAuthFailureHandler

protected val broadcaster: WsBroadcaster

protected val busListener: RawBusListener<WsSession>

private open var connector: ServerConnector

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

private open var server: Server

sessionRegistry

protected val sessionRegistry: WsSessionRegistry

SHUTDOWN_TIMEOUT_MS

private val SHUTDOWN_TIMEOUT_MS: Long = 10000

Functions

open fun builder(): JettyWsServer.Builder

fun close()

open fun getBroadcaster(): WsBroadcaster

open fun getLocalPort(): Int

getLocalSessionDispatcher

open fun getLocalSessionDispatcher(): LocalSessionDispatcher

getWsSubscriptionRegistry

open fun getWsSubscriptionRegistry(): WsSubscriptionRegistry

protected open fun onStart()

protected open fun onStop()

fun start()

translateException

protected open fun translateException(ex: Exception): RuntimeException