5.1.5

wow-core/me.ahoo.wow.event/DistributedDomainEventBus

DistributedDomainEventBus

interface DistributedDomainEventBus : DomainEventBus, DistributedMessageBus<DomainEventStream, EventStreamExchange>

Inheritors

MetricDistributedDomainEventBus

Properties

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>