wow-core/me.ahoo.wow.messaging.transport/TransportServerCommandExchange

TransportServerCommandExchange

class TransportServerCommandExchange<C : Any>(val message: CommandMessage<C>, val record: TransportRecord, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : ServerCommandExchange<C>

A command received from a Transport; acknowledging it acknowledges its record.

Constructors

TransportServerCommandExchange

constructor(message: CommandMessage<C>, record: TransportRecord, attributes: MutableMap<String, Any> = ConcurrentHashMap())

Properties

open override val attributes: MutableMap<String, Any>

open override val message: CommandMessage<C>

val record: TransportRecord

Functions

open override fun acknowledge(): Mono<Void>