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

MetricLocalDomainEventBus

class MetricLocalDomainEventBus(delegate: LocalDomainEventBus) : MetricDomainEventBus<LocalDomainEventBus> , LocalDomainEventBus

Constructors

MetricLocalDomainEventBus

constructor(delegate: LocalDomainEventBus)

Properties

override val delegate: LocalDomainEventBus

open override val name: String

open override val topicKind: TopicKind

Functions

open override fun close()

fun LocalDomainEventBus.metrizable(): LocalDomainEventBus

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

abstract fun send(message: DomainEventStream): Mono<Void>

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

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