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

InMemoryDomainEventBus

class InMemoryDomainEventBus(val sinkSupplier: (NamedAggregate) -> Sinks.Many<DomainEventStream> = { Sinks.many().multicast().onBackpressureBuffer() }) : 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.

Parameters

sinkSupplier

The function to create sinks for named aggregates

Constructors

InMemoryDomainEventBus

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

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

open override fun receive(namedAggregates: Set<NamedAggregate>): Flux<EventStreamExchange>

Receives messages for the specified named aggregates.

send

open override fun send(message: DomainEventStream): Mono<Void>

Sends a message through the in-memory bus.

subscriberCount

open override fun subscriberCount(namedAggregate: NamedAggregate): Int

Returns the number of subscribers for the specified named aggregate.

InMemoryDomainEventBus

Parameters

See also

Constructors

Properties

Functions