NSL WebSocket/xyz.noisif.nsl.websocket.jetty.adapter/JettyWsListenerAdapter

JettyWsListenerAdapter

open class JettyWsListenerAdapter : GenericWsListenerHandler<WsSession> , Session.Listener.AutoDemanding

Constructors

constructor(lifecycleListener: NetworkSessionLifecycleListener<WsSession>, busListener: RawBusListener<WsSession>, registry: WsSessionRegistry, rateLimiter: RateLimiter, envelopeSerializer: EnvelopeSerializer<out Any>, principalId: String)

Properties

busListener

protected val busListener: RawBusListener<S>

envelopeSerializer

private val envelopeSerializer: EnvelopeSerializer<out Any>

lifecycleListener

protected val lifecycleListener: NetworkSessionLifecycleListener<S>

log

protected val log: Logger

principalId

private val principalId: String

rateLimiter

private val rateLimiter: RateLimiter

registry

private val registry: WsSessionRegistry

registryTracker

protected val registryTracker: RegistryTracker<S>

sessionAdapter

protected open var sessionAdapter: S

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>)