wow-core/me.ahoo.wow.metrics/MetricDomainEventBus

MetricDomainEventBus

open class MetricDomainEventBus<T : DomainEventBus>(delegate: T) : AbstractMetricDecorator<T> , DomainEventBus, Metrizable

Inheritors

MetricLocalDomainEventBus

MetricDistributedDomainEventBus

Constructors

MetricDomainEventBus

constructor(delegate: T)

Properties

override val delegate: T

open override val name: String

open override val topicKind: TopicKind

Functions

open override fun close()

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

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

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

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