kernel/me.ahoo.wow.kernel/ExecutionReceiptContext

ExecutionReceiptContext

class ExecutionReceiptContext(val executionId: ExecutionId, receiptOf: String, causation: Causation, operator: Operator?, scope: Scope, val ids: Ids = IdGenerators.DEFAULT, headers: Map<String, String> = emptyMap(), commandTypes: CommandTypes = CommandTypes.NONE, contextQueries: ContextQueries = ContextQueries.NONE, codec: EventCodec = EventCodec(), calls: CommandCalls = CommandCalls.NONE, sends: SagaSends? = null) : SagaContext, Derivation

The context of a saga's handler of a receipt: of the rejection of the command receiptOf, by an @OnRejected handler, or of its commit, by an @OnCommitted one. Handling the same receipt again, after a retry or a second delivery, derives the same requests, which the kernel does not decide twice: each command's id and request id are compensationId of receiptOf, this execution, and what it asks (its target, its command type and its business key or occurrence), as a saga's derived commands are keyed (ExecutionSagaContext.derivedId). Each command's causation is the command receiptOf, in the chain of its root (causation), and its operator and scope are that command's, and so are its headers, the request facts it inherited (me.ahoo.wow.api.decide.RequestFacts.PROPAGATED). It schedules, cancels and calls as every saga context does (ExecutionSagaContext): its schedules written by codec, its calls through calls.

Constructors

constructor(executionId: ExecutionId, receiptOf: String, causation: Causation, operator: Operator?, scope: Scope, ids: Ids = IdGenerators.DEFAULT, headers: Map<String, String> = emptyMap(), commandTypes: CommandTypes = CommandTypes.NONE, contextQueries: ContextQueries = ContextQueries.NONE, codec: EventCodec = EventCodec(), calls: CommandCalls = CommandCalls.NONE, sends: SagaSends? = null)