retry
suspend fun retry(subscription: SubscriptionId, ref: AggregateRef, failedAt: Long? = null): ParkedOps.Outcome
Handles subscription's parked ref again from where it is parked, whatever its retry spec says: at once when this node owns its partition, else by a request to the owner. With failedAt, only the parking at that time (ParkedAggregate.failedAt, as the operator saw it): Outcome.STALE when the entry was parked at another. Without, the current parking: a retry only handles the parked streams again.