LocalStateEventBus

Local state event bus that handles message routing within the same JVM instance. Messages are processed synchronously without network communication.

Properties

open override val topicKind: TopicKind

The topic kind for state events.

open override fun close()

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

Wraps a LocalStateEventBus with metrics collection capabilities. Returns a MetricLocalStateEventBus that collects metrics on state event operations.

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

Receives messages for the specified named aggregates.

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

Sends a message through the message bus.

abstract fun subscriberCount(namedAggregate: NamedAggregate): Int

Returns the number of subscribers for the specified named aggregate.