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

TracingLocalEventBus

class TracingLocalEventBus(val delegate: LocalDomainEventBus, val producerInstrumenter: Instrumenter<DomainEventStream, Unit> = EventProducerInstrumenter.INSTRUMENTER) : TracingMessageBus<DomainEventStream, EventStreamExchange, LocalDomainEventBus> , LocalDomainEventBus

Constructors

TracingLocalEventBus

constructor(delegate: LocalDomainEventBus, producerInstrumenter: Instrumenter<DomainEventStream, Unit> = EventProducerInstrumenter.INSTRUMENTER)

Properties

open override val delegate: LocalDomainEventBus

producerInstrumenter

open override val producerInstrumenter: Instrumenter<DomainEventStream, Unit>

open override val topicKind: TopicKind

Functions

open override fun close()

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

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

fun LocalDomainEventBus.tracing(): LocalDomainEventBus