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.

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(namedAggregates: Set<NamedAggregate>): Flux<E>

Receives messages from both local and distributed buses.

send

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

Sends a message using local-first routing strategy.