NSL Netclient/xyz.noisif.nsl.netclient.websocket.jetty/JettyWsClient

JettyWsClient

open class JettyWsClient : GenericWsClient

Constructors

JettyWsClient

private constructor(builder: GenericWsClient.AbstractBuilder<out Any>)

Types

Builder

open class Builder : GenericWsClient.AbstractBuilder<JettyWsClient.Builder>

Properties

clientsRegistry

protected val clientsRegistry: ClientRegistry<T>

connectTimeout

protected val connectTimeout: Duration

heartbeatManager

private val heartbeatManager: WsHeartbeatManager

initialized

private val initialized: AtomicBoolean

jettyWsClient

private open var jettyWsClient: WebSocketClient

log

protected val log: Logger

reconnectManager

private val reconnectManager: WsReconnectManager

running

private val running: AtomicBoolean

sessionRegistry

protected val sessionRegistry: WsClientSessionRegistry

ticker

private val ticker: ScheduledExecutorService

workerPool

private val workerPool: TaskExecutor

Functions

builder

open fun builder(): JettyWsClient.Builder

fun close()

isConnected

open fun isConnected(group: ClientGroup): Boolean

open fun isConnected(): Boolean

onClientGroupStart

protected open fun onClientGroupStart(clientGroup: ClientGroup, config: WsClientGroupConfig, req: WsClientUpgradeRequest, sessionCodec: WsSessionCodec, lifecycleListener: NetworkSessionLifecycleListener<WsClientSession>)

onStart

protected abstract fun onStart()

protected open fun onStart()

onStop

protected abstract fun onStop()

protected open fun onStop()

send

open fun send(clientGroup: ClientGroup, message: Array<Byte>)

open fun send(clientGroup: ClientGroup, message: String)

open fun send(message: Array<Byte>)

open fun send(message: String)

sendEnvelope

open fun sendEnvelope(clientGroup: ClientGroup, opCode: OpCode, data: Any)

open fun sendEnvelope(opCode: OpCode)

open fun sendEnvelope(opCode: OpCode, data: Any)

open fun sendEnvelope(clientGroup: ClientGroup, opCode: OpCode)

sendObject

open fun sendObject(clientGroup: ClientGroup, object: Any)

start

fun start()

translateException

protected open fun translateException(ex: Exception): RuntimeException