Class PullQueueRegistrationState

java.lang.Object
io.superdurable.dex.PullQueueRegistrationState
public final class PullQueueRegistrationState extends Object
Describes one slot kind in an immutable pull readiness snapshot.

Obtain entries from PullRegistrationState.getQueues(). A registered stream clears the slot kind's last permanent error. Treat the error object as immutable.

  • Method Details

    • getQueue

      public String getQueue()
      Returns the slot kind through the legacy queue accessor.
      Returns:
      POLL_WORKER_SLOT_KIND_STEP_AND_RPC or POLL_WORKER_SLOT_KIND_RPC_ONLY

    • hasRegisteredStream

      public boolean hasRegisteredStream()
      Reports whether a stream is currently registered for this slot kind.
      Returns:
      true while at least one stream has a Registered acknowledgement

    • getLastPermanentError

      public Throwable getLastPermanentError()
      Returns the most recent permanent rejection, cleared by re-registration.
      Returns:
      the original transport error, or null if no permanent error remains