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

StateEventBus

interface StateEventBus : MessageBus<StateEvent<*>, StateEventExchange<*>> , TopicKindCapable

Message bus for publishing and subscribing to state events. State events combine domain events with the resulting aggregate state, enabling subscribers to react to both the event and the current state.

This bus is specifically designed for state events with topic kind STATE_EVENT.

Inheritors

LocalFirstStateEventBus

LocalStateEventBus

DistributedStateEventBus

MetricStateEventBus

Properties

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

abstract 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

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

Sends a message through the message bus.