resolveAnywhere

abstract suspend fun resolveAnywhere(subscription: SubscriptionId, ref: AggregateRef): ParkedAggregate?

Resolves the entry parking ref for subscription by removing it, after the aggregate was retried successfully or the operator chose to skip it: either way the subscription handles the aggregate's entries again. Which of the two happened is the caller's to publish; the ledger only holds what is still parked.

It removes the entry wherever it is parked, for the callers that act on the ledger without a worker of the aggregate's partition: an operator's skip on a node where no worker holds the aggregate, the timers' parked entries, and the import of 9.x compensations. A worker resolves in its own partition (resolve).

Return

the removed entry, or null when the aggregate was not parked.