TracingLocalStateEventBus

Constructors

constructor(delegate: LocalStateEventBus, producerInstrumenter: Instrumenter<StateEvent<*>, Unit> = StateEventProducerInstrumenter.INSTRUMENTER)

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

open override val topicKind: TopicKind

open override fun close()

open override fun receive(namedAggregates: Set<NamedAggregate>): Flux<StateEventExchange<*>>

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