GenericWsListenerHandler

Constructors

protected constructor(registryTracker: RegistryTracker<S>, lifecycleListener: NetworkSessionLifecycleListener<S>, busListener: RawBusListener<S>)

protected val log: Logger

protected open var sessionAdapter: S

private val UNKNOWN_SESSION: String = "UNKNOWN_PENDING_SESSION"

protected open fun checkRateLimit(): Boolean

protected open fun cleanupSession()

protected open fun getSafeSessionId(): String

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

protected open fun handleConnect()

protected open fun handleError(cause: Throwable)

private open fun handleFatalError(context: String, ex: Exception)

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

protected open fun onBusinessError()

protected open fun onRateLimitExceeded()

protected open fun onText(message: String)

private open fun runOnSuccess(onSuccess: Runnable)