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

LocalFirstDomainEventBus

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

Domain event bus that prioritizes local processing before distributed publishing.

This implementation extends LocalFirstMessageBus to provide a hybrid event bus that first processes events locally (for immediate consistency) and then publishes them to a distributed bus (for cross-service communication).

Parameters

distributedBus

The distributed event bus

localBus

The local event bus (default: InMemoryDomainEventBus)

Constructors

LocalFirstDomainEventBus

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

Creates a new LocalFirstDomainEventBus with the specified buses

Properties

distributedBus

open override val distributedBus: DistributedDomainEventBus

The distributed event bus for cross-service communication

localBus

open override val localBus: LocalDomainEventBus

The local event bus for in-process handling (default: InMemoryDomainEventBus)

topicKind

open override val topicKind: TopicKind

Functions

open override fun close()

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

receive

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

Receives messages for the specified named aggregates.

send

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

Sends a message through the message bus.

LocalFirstDomainEventBus

Parameters

See also

Constructors

Properties

Functions