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 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.