LocalCommandWaitNotifier

Local implementation of CommandWaitNotifier for in-process notifications. This notifier forwards wait signals to registered wait handles within the same JVM instance.

Parameters

waitCoordinator

The coordinator containing active wait handles.

Constructors

Link copied to clipboard
constructor(waitCoordinator: WaitCoordinator)

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
open override fun notify(commandWaitEndpoint: String, waitSignal: WaitSignal): Mono<Void>

Notifies local wait handles if the signal belongs to this JVM instance. Uses the wait coordinator to forward signals to waiting clients.

Link copied to clipboard
open override fun notifyAndForget(commandWaitEndpoint: String, waitSignal: WaitSignal)

Local notification completes synchronously, so the fire-and-forget path skips the per-signal Mono.fromRunnable and subscriber allocations of the default implementation. Notification failures are logged instead of propagating to the notifying pipeline, matching the dropped-error semantics of notify(...).subscribe().

Link copied to clipboard

Extension function to notify and forget using an extracted wait plan. Only sends notification if the wait plan should be notified for this signal.