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

TracingLocalStateEventBus

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

Constructors

TracingLocalStateEventBus

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

Properties

open override val delegate: LocalStateEventBus

producerInstrumenter

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

Functions

sendIfSubscribed

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

subscriberCount

open override fun subscriberCount(namedAggregate: NamedAggregate): Int