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

Receives messages for the specified named aggregates.

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

Sends a message through the message bus.

abstract fun subscriberCount(namedAggregate: NamedAggregate): Int

Returns the number of subscribers for the specified named aggregate.