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

TransportStateEventExchange

class TransportStateEventExchange<S : Any>(val message: StateEvent<S>, val record: TransportRecord, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : StateEventExchange<S>

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

Constructors

TransportStateEventExchange

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

Properties

open override val attributes: MutableMap<String, Any>

open override val message: StateEvent<S>

val record: TransportRecord

Functions

open override fun acknowledge(): Mono<Void>