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

TracingMessageBus

interface TracingMessageBus<M : Message<*, *>, E : MessageExchange<*, M>, B : MessageBus<M, E>> : Traced, MessageBus<M, E> , Decorator<B>

Inheritors

TracingLocalCommandBus

TracingDistributedCommandBus

TracingLocalEventBus

TracingDistributedEventBus

TracingLocalStateEventBus

TracingDistributedStateEventBus

Properties

abstract val delegate: B

producerInstrumenter

abstract val producerInstrumenter: Instrumenter<M, Unit>

Functions

open override fun close()

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

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

runtimeReceiver

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

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