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

TracingDistributedEventBus

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

Constructors

TracingDistributedEventBus

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

Properties

open override val delegate: DistributedDomainEventBus

producerInstrumenter

open override val producerInstrumenter: Instrumenter<DomainEventStream, Unit>

open override val topicKind: TopicKind

Functions

open override fun close()

open override fun receive(subscription: MessageSubscription): Flux<EventStreamExchange>

open override fun receiver(subscription: MessageSubscription): MessageReceiver<EventStreamExchange>

runtimeReceiver

open override fun runtimeReceiver(subscription: MessageSubscription): MessageReceiver<EventStreamExchange>

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

fun DistributedDomainEventBus.tracing(): DistributedDomainEventBus