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

CommandGateway

interface CommandGateway : CommandBus

Command Gateway interface for sending commands and waiting for their results.

The Command Gateway provides a high-level API for sending commands to aggregates and optionally waiting for their processing results. It supports various waiting plans to control how long to wait and what stage of processing to wait for. Implementations that report enforcesCommandWaitTimeout must enforce WaitPlan.timeout as an end-to-end deadline for sendAndWait and sendAndWaitStream.

Author

ahoo wang

See also

Inheritors

DefaultCommandGateway

Properties

enforcesCommandWaitTimeout

open val enforcesCommandWaitTimeout: Boolean

Whether this gateway enforces WaitPlan.timeout itself.

Functions

abstract fun <C : Any> sendAndWait(command: CommandMessage<C>, waitPlan: WaitPlan): Mono<CommandResult>

Sends a command and waits for the final result.

sendAndWaitForProcessed

open fun <C : Any> sendAndWaitForProcessed(command: CommandMessage<C>): Mono<CommandResult>

Sends a command and waits until it is fully processed by the aggregate.

sendAndWaitForSent

open fun <C : Any> sendAndWaitForSent(command: CommandMessage<C>): Mono<CommandResult>

Sends a command and waits until it is successfully sent to the command bus.

sendAndWaitForSnapshot

open fun <C : Any> sendAndWaitForSnapshot(command: CommandMessage<C>): Mono<CommandResult>

Sends a command and waits until the aggregate state is snapshotted.

sendAndWaitStream

abstract fun <C : Any> sendAndWaitStream(command: CommandMessage<C>, waitPlan: WaitPlan): Flux<CommandResult>

Sends a command and returns a stream of command results as processing progresses.