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

MetricDistributedDomainEventBus

class MetricDistributedDomainEventBus(delegate: DistributedDomainEventBus) : MetricDomainEventBus<DistributedDomainEventBus> , DistributedDomainEventBus

Constructors

MetricDistributedDomainEventBus

constructor(delegate: DistributedDomainEventBus)

Properties

override val delegate: DistributedDomainEventBus

open override val name: String

open override val topicKind: TopicKind

Functions

open override fun close()

fun DistributedDomainEventBus.metrizable(): DistributedDomainEventBus

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>