send

open override fun send(message: M): Mono<Void>

Sends a message using local-first routing strategy.

If local-first routing is enabled, the bus attempts local delivery to processing-open receivers. The distributed copy is marked locally handled only after every targeted receiver confirms runtime admission; otherwise it remains eligible for distributed processing.

Return

A Mono that completes when sending is done

Parameters

message

The message to send