StateEventBus

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

Properties

Link copied to clipboard
open override val topicKind: TopicKind

The topic kind for state events.

Functions

Link copied to clipboard
open override fun close()

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

Link copied to clipboard
abstract fun receive(namedAggregates: Set<NamedAggregate>): Flux<StateEventExchange<*>>

Receives messages for the specified named aggregates.

Link copied to clipboard
abstract fun send(message: StateEvent<*>): Mono<Void>

Sends a message through the message bus.