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

TransportEventStreamExchange

class TransportEventStreamExchange(val message: DomainEventStream, val record: TransportRecord, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : EventStreamExchange

An event stream received from a Transport; acknowledging it acknowledges its record.

Constructors

TransportEventStreamExchange

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

Properties

open override val attributes: MutableMap<String, Any>

open override val message: DomainEventStream

val record: TransportRecord

Functions

open override fun acknowledge(): Mono<Void>