wow-core/me.ahoo.wow.messaging/InMemoryMessageBus

InMemoryMessageBus

@ThreadSafe

abstract class InMemoryMessageBus<M : Message<*, *>, NamedAggregate, E : MessageExchange<*, M>> : LocalMessageBus<M, E>

Abstract base class for in-memory message bus implementations.

This class provides a local message bus that uses Reactor Sinks for message distribution within a single JVM instance. Messages are sent to subscribers via sinks and can be received by subscribing to the appropriate named aggregates.

Type Parameters

The type of message, must implement both Message and NamedAggregate

The type of message exchange

Inheritors

InMemoryCommandBus

InMemoryDomainEventBus

InMemoryStateEventBus

Constructors

InMemoryMessageBus

constructor()

Types

Companion

object Companion

Properties

sinkSupplier

abstract val sinkSupplier: (NamedAggregate) -> Sinks.Many<M>

Supplier function that creates a sink for a given named aggregate.

Functions

open override fun close()

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

createExchange

abstract fun M.createExchange(): E

Creates a message exchange from this message.

receive

open override fun receive(subscription: MessageSubscription): Flux<E>

Receives messages for the specified named aggregates.

receiver

open fun receiver(subscription: MessageSubscription): MessageReceiver<E>

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

runtimeReceiver

open override fun runtimeReceiver(subscription: MessageSubscription): MessageReceiver<E>

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

send

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

Sends a message through the in-memory bus.

sendIfSubscribed

open override fun sendIfSubscribed(message: M): Mono<Boolean>

Attempts local delivery only while a processing subscriber is routable.

subscriberCount

open override fun subscriberCount(namedAggregate: NamedAggregate): Int

Returns the number of subscribers for the specified named aggregate.