NSL Netclient/xyz.noisif.nsl.netclient.websocket.jetty.adapter/JettyWsClientListenerAdapter

JettyWsClientListenerAdapter

open class JettyWsClientListenerAdapter : GenericWsListenerHandler<WsClientSession> , Session.Listener.AutoDemanding

Constructors

constructor(clientGroup: ClientGroup, groupConfig: WsClientGroupConfig, sessionRegistry: WsClientSessionRegistry, sessionCodec: WsSessionCodec, lifecycleListener: NetworkSessionLifecycleListener<WsClientSession>)

Properties

busListener

protected val busListener: RawBusListener<S>

clientGroup

private val clientGroup: ClientGroup

groupConfig

private val groupConfig: WsClientGroupConfig

lifecycleListener

protected val lifecycleListener: NetworkSessionLifecycleListener<S>

log

protected val log: Logger

registryTracker

protected val registryTracker: RegistryTracker<S>

sessionAdapter

protected open var sessionAdapter: S

sessionCodec

private val sessionCodec: WsSessionCodec

sessionRegistry

private val sessionRegistry: WsClientSessionRegistry

UNKNOWN_SESSION

private val UNKNOWN_SESSION: String = "UNKNOWN_PENDING_SESSION"

Functions

checkRateLimit

protected open fun checkRateLimit(): Boolean

cleanupSession

protected open fun cleanupSession()

completeCallback

private open fun completeCallback(callback: Callback, error: Throwable)

getSafeSessionId

protected open fun getSafeSessionId(): String

handleClose

protected open fun handleClose(statusCode: Int, reason: String)

handleConnect

protected open fun handleConnect()

handleError

protected open fun handleError(cause: Throwable)

onBinary

protected open fun onBinary(payload: ByteBuffer, onSuccess: Runnable, onFailure: Consumer<Throwable>)

onBusinessError

protected open fun onBusinessError()

onRateLimitExceeded

protected open fun onRateLimitExceeded()

onText

protected open fun onText(message: String)

onWebSocketBinary

open fun onWebSocketBinary(payload: ByteBuffer, callback: Callback)

onWebSocketClose

open fun onWebSocketClose(statusCode: Int, reason: String)

open fun onWebSocketClose(statusCode: Int, reason: String, callback: Callback)

onWebSocketError

open fun onWebSocketError(cause: Throwable)

onWebSocketFrame

open fun onWebSocketFrame(frame: Frame, callback: Callback)

onWebSocketOpen

open fun onWebSocketOpen(session: Session)

onWebSocketPartialBinary

open fun onWebSocketPartialBinary(payload: ByteBuffer, last: Boolean, callback: Callback)

onWebSocketPartialText

open fun onWebSocketPartialText(payload: String, last: Boolean)

onWebSocketPing

open fun onWebSocketPing(payload: ByteBuffer)

onWebSocketPong

open fun onWebSocketPong(payload: ByteBuffer)

onWebSocketText

open fun onWebSocketText(message: String)

processMessageSafe

protected open fun processMessageSafe(action: RunnableWithException, onSuccess: Runnable, onFailure: Consumer<Throwable>)