wow-core/me.ahoo.wow.messaging/MessageBus

MessageBus

interface MessageBus<M : Message<*, *>, E : MessageExchange<*, M>> : AutoCloseable

Represents a message bus for sending and receiving messages in a distributed system.

This interface provides the core functionality for message-based communication between different components of the system. Implementations can be local or distributed.

Type Parameters

The type of message being handled, must extend Message

The type of message exchange, must extend MessageExchange

Inheritors

DistributedMessageBus

Functions

open override fun close()

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

receive

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

Receives messages for the specified subscription.

receiver

open fun receiver(subscription: MessageSubscription): MessageReceiver<E>

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

runtimeReceiver

open fun runtimeReceiver(subscription: MessageSubscription): MessageReceiver<E>

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

send

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

Sends a message through the message bus.