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

DistributedStateEventBus

interface DistributedStateEventBus : StateEventBus, DistributedMessageBus<StateEvent<*>, StateEventExchange<*>>

Distributed state event bus that handles message routing across multiple instances or services. Messages are published to a distributed messaging system for cross-instance communication.

Inheritors

MetricDistributedStateEventBus

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.

metrizable

fun DistributedStateEventBus.metrizable(): DistributedStateEventBus

Wraps a DistributedStateEventBus with metrics collection capabilities. Returns a MetricDistributedStateEventBus that collects metrics on state event operations.

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.