TracingLocalCommandBus

Constructors

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

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

open override val topicKind: TopicKind

open override fun close()

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

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