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(namedAggregates: Set<NamedAggregate>): Flux<StateEventExchange<*>>

Receives messages for the specified named aggregates.

send

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

Sends a message through the message bus.