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(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.