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