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

TracingLocalCommandBus

class TracingLocalCommandBus(val delegate: LocalCommandBus, val producerInstrumenter: Instrumenter<CommandMessage<*>, Unit> = CommandProducerInstrumenter.INSTRUMENTER) : TracingMessageBus<CommandMessage<*>, ServerCommandExchange<*>, LocalCommandBus> , LocalCommandBus

Constructors

TracingLocalCommandBus

constructor(delegate: LocalCommandBus, producerInstrumenter: Instrumenter<CommandMessage<*>, Unit> = CommandProducerInstrumenter.INSTRUMENTER)

Properties

open override val delegate: LocalCommandBus

producerInstrumenter

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

Functions

sendIfSubscribed

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

subscriberCount

open override fun subscriberCount(namedAggregate: NamedAggregate): Int