Class PullRegistrationState

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

Use Worker.getPullRegistrationState() for readiness probes after initial startup. Transient failures, reconnects, and stop preserve readiness after a STEP_AND_RPC stream and any configured RPC_ONLY stream have registered once. A permanent rejection makes readiness false while its slot kind has no registered stream. Readiness is never true after Worker start fails because maxConcurrentTasks exceeds the Server's per-Worker limit. 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 required slot kinds registered once unless a slot kind has a permanent error and no registered stream

    • getQueues

      public List<PullQueueRegistrationState> getQueues()
      Returns slot-kind snapshots through the legacy queue collection accessor.
      Returns:
      an immutable list ordered STEP_AND_RPC then RPC_ONLY when configured