MetricCommandBus

Constructors

constructor(delegate: T)

override val delegate: T

open override val name: String

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>

fun <M> Flux<M>.tagSource(): Flux<M>

fun <M> Mono<M>.tagSource(): Mono<M>