Class PullRegistrationState

java.lang.Object
io.superdurable.dex.PullRegistrationState
public final class PullRegistrationState extends Object
Provides an independent, immutable snapshot of pull queue readiness.

Use Worker.getPullRegistrationState() for readiness probes after initial startup. Transient failures, reconnects, and stop preserve readiness after every queue has registered once. A permanent rejection makes readiness false while its queue has no registered stream. See Worker.waitPullRegistered(java.time.Duration) for a startup example.

  • Method Details

    • isReady

      public boolean isReady()
      Reports whether initial registration completed without an uncovered permanent rejection.
      Returns:
      true after all queues registered once unless a queue has a permanent error and no registered stream

    • getQueues

      public List<PullQueueRegistrationState> getQueues()
      Returns queue snapshots ordered by app Worker ID and then sorted Flow types.
      Returns:
      an immutable list