wow-core/me.ahoo.wow.command/LocalFirstCommandBus

LocalFirstCommandBus

class LocalFirstCommandBus(val distributedBus: DistributedCommandBus, val localBus: LocalCommandBus = InMemoryCommandBus()) : CommandBus, LocalFirstMessageBus<CommandMessage<*>, ServerCommandExchange<*>>

Command bus that prioritizes local processing before falling back to distributed processing. Void commands are automatically configured to skip local-first behavior since they don't require waiting for results.

Parameters

distributedBus

The distributed command bus for fallback processing.

localBus

The local command bus for primary processing. Defaults to InMemoryCommandBus.

Constructors

LocalFirstCommandBus

constructor(distributedBus: DistributedCommandBus, localBus: LocalCommandBus = InMemoryCommandBus())

Properties

distributedBus

open override val distributedBus: DistributedCommandBus

localBus

open override val localBus: LocalCommandBus

topicKind

open override val topicKind: TopicKind

The topic kind for command messages.

Functions

open override fun close()

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

receive

open fun receive(subscription: MessageSubscription): Flux<ServerCommandExchange<*>>

Receives messages for the specified subscription.

receiver

open fun receiver(subscription: MessageSubscription): MessageReceiver<ServerCommandExchange<*>>

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

runtimeReceiver

open fun runtimeReceiver(subscription: MessageSubscription): MessageReceiver<ServerCommandExchange<*>>

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

send

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

Sends a command message, prioritizing local processing. Void commands are automatically configured to not use local-first behavior.