wow-opentelemetry/me.ahoo.wow.opentelemetry.messaging/TracingDistributedStateEventBus

TracingDistributedStateEventBus

class TracingDistributedStateEventBus(val delegate: DistributedStateEventBus, val producerInstrumenter: Instrumenter<StateEvent<*>, Unit> = StateEventProducerInstrumenter.INSTRUMENTER) : TracingMessageBus<StateEvent<*>, StateEventExchange<*>, DistributedStateEventBus> , DistributedStateEventBus

Constructors

TracingDistributedStateEventBus

constructor(delegate: DistributedStateEventBus, producerInstrumenter: Instrumenter<StateEvent<*>, Unit> = StateEventProducerInstrumenter.INSTRUMENTER)

Properties

open override val delegate: DistributedStateEventBus

producerInstrumenter

open override val producerInstrumenter: Instrumenter<StateEvent<*>, Unit>

open override val topicKind: TopicKind

Functions

open override fun close()

open override fun receive(namedAggregates: Set<NamedAggregate>): Flux<StateEventExchange<*>>

open override fun send(message: StateEvent<*>): Mono<Void>

fun DistributedStateEventBus.tracing(): DistributedStateEventBus