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.

Receives messages for the specified subscription.

Creates a single message source with an explicit transport readiness boundary.

Creates the message source owned by a me.ahoo.wow.runtime.WowRuntime dispatcher.

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

Sends a message through the message bus.

Attempts local delivery only while a processing subscriber is routable.

abstract fun subscriberCount(namedAggregate: NamedAggregate): Int

Returns the number of subscribers for the specified named aggregate.