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

DomainEventBus

interface DomainEventBus : MessageBus<DomainEventStream, EventStreamExchange> , TopicKindCapable

Domain Event Bus interface for publishing and subscribing to domain event streams.

This interface defines the contract for a message bus that handles domain event streams, ensuring ordered publication and processing of events per aggregate ID.

Key characteristics:

Ordered Publication: Events are published in order per aggregate ID
Ordered Processing: Events are processed in the order they were published

Inheritors

LocalDomainEventBus

DistributedDomainEventBus

NoOpDomainEventBus

LocalFirstDomainEventBus

MetricDomainEventBus

Properties

topicKind

open override val topicKind: TopicKind

Functions

open override fun close()

Closes the message bus and releases any resources. Default implementation does nothing.

receive

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

Receives messages for the specified named aggregates.

send

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

Sends a message through the message bus.

DomainEventBus

See also

Inheritors

Properties

Functions