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

open override val distributedBus: DistributedStateEventBus

open override val localBus: LocalStateEventBus

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.

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

Receives messages for the specified named aggregates.

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

Sends a message through the message bus.