NSL Netclient/xyz.noisif.nsl.netclient.websocket/GenericWsClient

GenericWsClient

abstract class GenericWsClient : NetworkClient<WsClientGroupConfig> , WsClient

Inheritors

JettyWsClient

Constructors

GenericWsClient

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

Types

AbstractBuilder

protected abstract class AbstractBuilder<B : GenericWsClient.AbstractBuilder<B>?> : NetworkClient.AbstractBaseBuilder<WsClientGroupConfig, B>

Properties

clientsRegistry

protected val clientsRegistry: ClientRegistry<T>

connectTimeout

protected val connectTimeout: Duration

heartbeatManager

private val heartbeatManager: WsHeartbeatManager

initialized

private val initialized: AtomicBoolean

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

applyAuthenticator

private open fun applyAuthenticator(req: WsClientUpgradeRequest, config: WsClientGroupConfig)

applyHeaders

private open fun applyHeaders(req: WsClientUpgradeRequest, config: WsClientGroupConfig)

fun close()

connectWithRetry

private open fun connectWithRetry(group: ClientGroup, config: WsClientGroupConfig, attempt: Int)

executeOnSession

private open fun executeOnSession(clientGroup: ClientGroup, type: String, action: Consumer<WsClientSession>)

isConnected

open fun isConnected(group: ClientGroup): Boolean

open fun isConnected(): Boolean

logMissingSession

private open fun logMissingSession(group: ClientGroup, type: String)

onClientGroupStart

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

onStart

protected open fun onStart()

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