Committed
class Committed<C : Any> @InternalWowApi constructor(val commandId: String, val commandType: String, val ref: AggregateRef, val version: Int, val result: CommandResult, val causation: Causation, val executionId: ExecutionId, val operator: Operator? = null, val scope: Scope = Scope.NONE, val headers: Map<String, String> = emptyMap()) : CommandReceipt<C>
The command was committed on ref (its id the one the target gave it when the command named none) at version, with result, the command's outcome at its committed hop. A request the target had already committed is answered with its original aggregate and version, CommandResult.duplicate set.
Only the commands an @OnCommitted handler takes ask for this receipt: a command the saga sends to another context carries the request in its replyTo, and the target sends the receipt once the command is committed. It carries no state: the contract across contexts is the command's result; a saga that follows the target's later state reads its published stream.
Constructors
Link copied to clipboard
constructor(commandId: String, commandType: String, ref: AggregateRef, version: Int, result: CommandResult, causation: Causation, executionId: ExecutionId, operator: Operator? = null, scope: Scope = Scope.NONE, headers: Map<String, String> = emptyMap())
Properties
Functions
Link copied to clipboard
fun copyWith(commandId: String = this.commandId, commandType: String = this.commandType, ref: AggregateRef = this.ref, version: Int = this.version, result: CommandResult = this.result, causation: Causation = this.causation, executionId: ExecutionId = this.executionId, operator: Operator? = this.operator, scope: Scope = this.scope, headers: Map<String, String> = this.headers): CommandReceipt.Committed<C>
This Committed with the given fields replaced: Wow's own copy, left out of the ABI.