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

LocalFirstMessageBus

interface LocalFirstMessageBus<M : Message<*, *>, NamedAggregate, Copyable<*>, E : MessageExchange<*, M>> : MessageBus<M, E>

A message bus that prioritizes local message handling before distributed routing.

This bus first attempts to send messages locally within the JVM, and only sends to the distributed bus if local sending fails or there are no local subscribers. It also merges local and distributed message streams for receiving.

Type Parameters

The message type, must implement Message, NamedAggregate, and Copyable

The message exchange type

Inheritors

LocalFirstCommandBus

LocalFirstDomainEventBus

LocalFirstStateEventBus

Properties

distributedBus

abstract val distributedBus: DistributedMessageBus<M, E>

The distributed message bus for fallback routing.

localBus

abstract val localBus: LocalMessageBus<M, E>

The local message bus for in-JVM routing.

Functions

open override fun close()

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

receive

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

Receives messages from both local and distributed buses.

receiver

open override 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 using local-first routing strategy.