wow-core/me.ahoo.wow.command.wait/LocalCommandWaitNotifier

LocalCommandWaitNotifier

class LocalCommandWaitNotifier(waitStrategyRegistrar: WaitStrategyRegistrar) : CommandWaitNotifier

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

Parameters

waitStrategyRegistrar

The registrar containing active wait strategies.

Constructors

LocalCommandWaitNotifier

constructor(waitStrategyRegistrar: WaitStrategyRegistrar)

Types

Companion

object Companion

Functions

notify

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

Notifies local wait strategies if the signal belongs to this JVM instance. Uses the wait strategy registrar to forward signals to waiting clients.

notifyAndForget

open fun notifyAndForget(commandWaitEndpoint: String, waitSignal: WaitSignal)

Sends a wait signal notification asynchronously without waiting for completion. Uses bounded elastic scheduler to avoid blocking the calling thread.

notifyAndForget

fun CommandWaitNotifier.notifyAndForget(waiteStrategy: ExtractedWaitStrategy, waitSignal: WaitSignal)

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