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(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>

sendIfSubscribed

open override fun sendIfSubscribed(message: DomainEventStream): Mono<Boolean>

subscriberCount

open override fun subscriberCount(namedAggregate: NamedAggregate): Int

fun LocalDomainEventBus.tracing(): LocalDomainEventBus