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

InMemoryDomainEventBus

class InMemoryDomainEventBus(val sinkSupplier: (NamedAggregate) -> Sinks.Many<DomainEventStream> = { Sinks.unsafe().many().multicast().onBackpressureBuffer<DomainEventStream>().concurrent() }) : InMemoryMessageBus<DomainEventStream, EventStreamExchange> , LocalDomainEventBus

In-memory implementation of LocalDomainEventBus.

This class provides an in-memory message bus for domain events, suitable for testing or single-process applications. It uses reactive sinks to handle event publishing and subscription within the same JVM instance.

Constructors

constructor(sinkSupplier: (NamedAggregate) -> Sinks.Many<DomainEventStream> = { Sinks.unsafe().many().multicast().onBackpressureBuffer<DomainEventStream>().concurrent() })

Creates a new InMemoryDomainEventBus with the specified sink supplier

Properties

sinkSupplier

open override val sinkSupplier: (NamedAggregate) -> Sinks.Many<DomainEventStream>

Function to create reactive sinks for each named aggregate (default: multicast sink with buffer)

topicKind

open override val topicKind: TopicKind

Functions

open override fun close()

Closes the message bus and releases any resources. Default implementation does nothing.

createExchange

open override fun DomainEventStream.createExchange(): EventStreamExchange

Creates an EventStreamExchange from a DomainEventStream.

metrizable

fun LocalDomainEventBus.metrizable(): LocalDomainEventBus

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

receive