GenericWsSessionAdapter

Constructors

protected constructor(principalId: String, messageCodec: UnifiedMessageCodec)

protected val log: Logger

protected val sessionId: String

private val UNKNOWN_ENVELOPE: String = "UNKNOWN"

fun accept(payload: Array<Byte>)

fun accept(payload: String)

fun close(closeCode: CloseCode)

abstract fun isClosed(): Boolean

protected abstract fun onClose(code: Int, reason: String)

protected abstract fun onSend(message: Array<Byte>)

protected abstract fun onSend(message: String)

fun send(message: Array<Byte>)

fun send(message: String)

open fun sendEnvelope(opCode: OpCode)

fun sendEnvelope(opCode: OpCode, data: Any)

private open fun sendSafely(logAction: Runnable, transportAction: RunnableWithException)

fun unwrap(payload: Array<Byte>, typeResolver: (Integer) -> Class<out Any>): MessageEnvelope<out Any>

fun unwrap(payload: String, typeResolver: (Integer) -> Class<out Any>): MessageEnvelope<out Any>