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

LocalFirstDomainEventBus

class LocalFirstDomainEventBus(val distributedBus: DistributedDomainEventBus, val localBus: LocalDomainEventBus = InMemoryDomainEventBus()) : DomainEventBus, LocalFirstMessageBus<DomainEventStream, EventStreamExchange>

Constructors

LocalFirstDomainEventBus

constructor(distributedBus: DistributedDomainEventBus, localBus: LocalDomainEventBus = InMemoryDomainEventBus())

Properties

open override val distributedBus: DistributedDomainEventBus

open override val localBus: LocalDomainEventBus

open override val topicKind: TopicKind

Functions

open override fun close()

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

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