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

DomainEventBus

interface DomainEventBus : MessageBus<DomainEventStream, EventStreamExchange> , TopicKindCapable

Domain Event Bus.

  1. 领域事件发布有序性(per AggregateId)

  2. 领域事件处理有序性

Inheritors

Properties

Link copied to clipboard
open override val topicKind: TopicKind

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
abstract fun receive(namedAggregates: Set<NamedAggregate>): Flux<EventStreamExchange>
Link copied to clipboard
abstract fun send(message: DomainEventStream): Mono<Void>