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).

Constructors

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(subscription: MessageSubscription): Flux<EventStreamExchange>

Receives messages for the specified subscription.

receiver

open fun receiver(subscription: MessageSubscription): MessageReceiver<EventStreamExchange>

Creates a single message source with an explicit transport readiness boundary.

runtimeReceiver

open fun runtimeReceiver(subscription: MessageSubscription): MessageReceiver<EventStreamExchange>

Creates the message source owned by a me.ahoo.wow.runtime.WowRuntime dispatcher.

send

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

Sends a message through the message bus.

LocalFirstDomainEventBus

See also

Constructors

Properties

Functions