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

TracingDistributedCommandBus

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

Constructors

TracingDistributedCommandBus

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

Properties

open override val delegate: DistributedCommandBus

producerInstrumenter

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

open override val topicKind: TopicKind

Functions

open override fun close()

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

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

runtimeReceiver

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

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

fun DistributedCommandBus.tracing(): DistributedCommandBus