DistributedMessageBus

A distributed message bus that operates across multiple JVM instances or nodes.

This interface extends MessageBus and is designed for scenarios where message distribution needs to happen across a cluster or distributed system.

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.