NSL WebSocket/xyz.noisif.nsl.websocket.listener/ActionRouterWsMessageListener

ActionRouterWsMessageListener

open class ActionRouterWsMessageListener : EnvelopeBusListener<WsSession>

Constructors

ActionRouterWsMessageListener

private constructor(builder: ActionRouterWsMessageListener.Builder)

Types

open class Builder : EnvelopeBusListener.AbstractBuilder<WsSession, ActionRouterWsMessageListener.Builder>

Properties

private val actionGroup: ActionGroup

private val actionHandlers: Map<Integer, EnvelopeAction<S, out Any>>

val COMPARATOR: Comparator<Ordered>

componentProvider

private val componentProvider: ComponentProvider

HIGHEST_PRIORITY

val HIGHEST_PRIORITY: Int = 2147483647

protected val log: Logger

private val typeRegistry: Map<Integer, Class<out Any>>

Functions

open fun builder(): ActionRouterWsMessageListener.Builder

fun dispatch(session: S, message: Array<Byte>)

handleProcessingError

protected open fun handleProcessingError(session: WsSession, ex: Exception)

handleProcessUnknownAction

protected open fun handleProcessUnknownAction(session: WsSession, envelope: MessageEnvelope<out Any>)

open fun order(): Int

registerManually

protected open fun registerManually(action: EnvelopeAction<S, Void>)