wow-core/me.ahoo.wow.event/DistributedDomainEventBus

DistributedDomainEventBus

interface DistributedDomainEventBus : DomainEventBus, DistributedMessageBus<DomainEventStream, EventStreamExchange>

Distributed Domain Event Bus interface for cross-process event handling.

This interface extends DomainEventBus and DistributedMessageBus to provide event bus functionality across multiple processes or services.

See also

Inheritors

Properties

Link copied to clipboard
open override val topicKind: TopicKind

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
fun DistributedDomainEventBus.metrizable(): DistributedDomainEventBus

Wraps a DistributedDomainEventBus with metrics collection capabilities. Returns a MetricDistributedDomainEventBus that collects metrics on domain event operations.

Link copied to clipboard
abstract fun receive(subscription: MessageSubscription): Flux<EventStreamExchange>

Receives messages for the specified subscription.

Link copied to clipboard
open fun receiver(subscription: MessageSubscription): MessageReceiver<EventStreamExchange>

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

Link copied to clipboard
open fun runtimeReceiver(subscription: MessageSubscription): MessageReceiver<EventStreamExchange>

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

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

Sends a message through the message bus.

Generated by Dokka
© 2026 Copyright