FailureClass

How a subscription answers a failure of its handler (9.x RecoverableType).

Entries

Link copied to clipboard

The aggregate's own failure, which no retry changes (invalid data, a defect, a value refused for good): the aggregate is parked at once, without a retry.

Link copied to clipboard

The aggregate's own failure, which a retry may get past (a conflict, a slow call): the handler is retried within its budget (@Retry, wow.subscription.retry.*), then the aggregate is parked.

Link copied to clipboard

Not the aggregate's failure but its surroundings' (a store, a broker or a downstream service that is not reachable): every aggregate of the partition would fail the same way, so the subscription pauses the whole partition and retries until it is back, spending no aggregate's budget and parking none.

Link copied to clipboard

What the handler called is up but overloaded and asked it to come back later: a node refusing a command as busy (wow.command.busy), a wait that ran out (wow.wait.timeout), a query store's bulkhead (wow.query.busy), any 429 with a Retry-After. Never systemic: the subscription retries the entry with backoff and jitter (the Retry-After at least), throttles the partition's concurrency until handlings succeed again, and parks the aggregate once the backpressure budget is spent; it never pauses the partition.

Companion properties

Link copied to clipboard

Returns an immutable kotlin.enums.EnumEntries list containing the constants of this enum type, in the order they're declared.

Companion functions

Link copied to clipboard

Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)

Link copied to clipboard

Returns an array containing the constants of this enum type, in the order they're declared.