api/me.ahoo.wow.api.subscribe/ExecutionId

ExecutionId

data class ExecutionId(val subscription: String, val ref: AggregateRef, val version: Int)

One execution of a subscription's handler for one commit: the subscription (processor.function), the aggregate ref and the committed version. It is deterministic: handling the same commit again, after a retry, a replay or a lease handover, gives the same id. It is per stream: the idempotency key of an outside call is SubscriptionContext.invocationKey, which tells apart the calls of a handler for each event.

Constructors

ExecutionId

constructor(subscription: String, ref: AggregateRef, version: Int)

Properties

ref

val ref: AggregateRef

subscription

val subscription: String

version

val version: Int

Functions

toString

open override fun toString(): String

subscription:ref@version, such as example.cart-projection.onEvent:example.cart/tenant/c-1@3: the subscription with its % and : percent-escaped and the ref as its own text writes it (Escapes), so no two executions share a text.