LocalMessageBus

A local message bus that operates within a single JVM instance.

This interface extends MessageBus and provides additional functionality for monitoring subscriber counts in a local context.

The type of message being handled, must extend Message

The type of message exchange, must extend MessageExchange

Functions

open override fun close()

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

abstract fun receive(subscription: MessageSubscription): Flux<E>

Receives messages for the specified subscription.

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

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

abstract fun send(message: M): Mono<Void>

Sends a message through the message bus.

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

Attempts local delivery only while a processing subscriber is routable.

abstract fun subscriberCount(namedAggregate: NamedAggregate): Int

Returns the number of subscribers for the specified named aggregate.