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 slot kind 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 slot kind through the legacy queue accessor.

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 slot kind, POLL_WORKER_SLOT_KIND_STEP_AND_RPC or POLL_WORKER_SLOT_KIND_RPC_ONLY

cause - the original permanent transport error

Method Details

getQueue

public String getQueue()

Returns the rejected slot kind through the legacy queue accessor.

Returns:

the slot kind name, rather than a single routing queue