due
abstract suspend fun due(subscription: SubscriptionId, partitions: Collection<Int>, now: Long, after: AggregateRef? = null, limit: Int = DEFAULT_PAGE): List<ParkedAggregate>
Up to limit of subscription's entries in partitions that the owner of their partition looks at by now (epoch milliseconds): those whose ParkedAggregate.nextAttemptAt is null (new, retried, or changed by an operator since the owner last looked) or not after now; at ParkedAggregate.NEVER, every entry of partitions, as a node that acquires a partition reads them. Ordered as list orders them, after after (exclusive; null from the start): pass the last entry's ref as after to read the next page.