Class PullRegistrationError

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

java.lang.IllegalStateException

io.superdurable.dex.PullRegistrationError

All Implemented Interfaces:

Serializable

public final class PullRegistrationError
extends IllegalStateException

Identifies a permanent pull rejection leaving a queue without a registered stream.

Thrown by Worker.waitPullRegistered(java.time.Duration) before initial readiness, or by Worker.start() when stopping on permanent rejection is enabled. Permanent codes are InvalidArgument, ResourceExhausted, Unimplemented, PermissionDenied, and Unauthenticated. The cause is the original transport error. See the wait method for a startup example.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
PullRegistrationError(String queue, Throwable cause)	Creates a rejection retaining its original transport cause.

Method Summary

Modifier and Type	Method	Description
String	getQueue()	Returns the rejected queue name.

Methods inherited from class Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

PullRegistrationError

public PullRegistrationError(String queue,
 Throwable cause)

Creates a rejection retaining its original transport cause.

Parameters:

queue - the rejected Flow type or app Worker ID queue

cause - the original permanent transport error

Method Details

getQueue

public String getQueue()

Returns the rejected queue name.

Returns:

the Flow type or app Worker ID queue