wow-core/me.ahoo.wow.eventsourcing.state/LocalFirstStateEventBus

LocalFirstStateEventBus

class LocalFirstStateEventBus(val distributedBus: DistributedStateEventBus, val localBus: LocalStateEventBus = InMemoryStateEventBus()) : StateEventBus, LocalFirstMessageBus<StateEvent<*>, StateEventExchange<*>>

State event bus that prioritizes local message delivery before distributed delivery. Messages are first sent to local subscribers within the same JVM instance, then forwarded to the distributed bus for cross-instance communication. This ensures low-latency local processing while maintaining consistency across instances.

Parameters

distributedBus

The distributed state event bus for cross-instance messaging.

localBus

The local state event bus for same-instance messaging (default: InMemoryStateEventBus).

Constructors

LocalFirstStateEventBus

constructor(distributedBus: DistributedStateEventBus, localBus: LocalStateEventBus = InMemoryStateEventBus())

Properties

distributedBus

open override val distributedBus: DistributedStateEventBus

localBus

open override val localBus: LocalStateEventBus

topicKind

open override val topicKind: TopicKind

The topic kind for state events.

Functions

open override fun close()

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

receive

open fun receive(subscription: MessageSubscription): Flux<StateEventExchange<*>>

Receives messages for the specified subscription.

receiver

open fun receiver(subscription: MessageSubscription): MessageReceiver<StateEventExchange<*>>

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

runtimeReceiver

open fun runtimeReceiver(subscription: MessageSubscription): MessageReceiver<StateEventExchange<*>>

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

send

open fun send(message: StateEvent<*>): Mono<Void>

Sends a message through the message bus.