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

LocalDomainEventBus

interface LocalDomainEventBus : DomainEventBus, LocalMessageBus<DomainEventStream, EventStreamExchange>

Local Domain Event Bus interface for in-process event handling.

This interface extends DomainEventBus and LocalMessageBus to provide event bus functionality within the same process or JVM instance.

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

Wraps a LocalDomainEventBus with metrics collection capabilities. Returns a MetricLocalDomainEventBus that collects metrics on domain event operations.

Link copied to clipboard
abstract fun receive(namedAggregates: Set<NamedAggregate>): Flux<EventStreamExchange>

Receives messages for the specified named aggregates.

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

Sends a message through the message bus.

Link copied to clipboard
abstract fun subscriberCount(namedAggregate: NamedAggregate): Int

Returns the number of subscribers for the specified named aggregate.

Generated by Dokka
© 2025 Copyright