Class PullQueueRegistrationState

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

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

  • Method Details

    • getQueue

      public String getQueue()
      Returns the queue name.
      Returns:
      the registered Flow type or app Worker ID queue

    • hasRegisteredStream

      public boolean hasRegisteredStream()
      Reports whether a stream is currently registered for this queue.
      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