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

TracingMessageBus

interface TracingMessageBus<M : Message<*, *>, E : MessageExchange<*, M>, B : MessageBus<M, E>> : 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(namedAggregates: Set<NamedAggregate>): Flux<E>

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