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>

open override val topicKind: TopicKind

Functions

open override fun close()

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

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

runtimeReceiver

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

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

sendIfSubscribed

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

subscriberCount

open override fun subscriberCount(namedAggregate: NamedAggregate): Int

fun LocalStateEventBus.tracing(): LocalStateEventBus