Class FlowClosingException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

io.superdurable.dex.exceptions.DexServiceException

io.superdurable.dex.exceptions.FlowClosingException

All Implemented Interfaces:

Serializable

public final class FlowClosingException
extends DexServiceException

Reports a request rejected while Dex closes a Flow.

Catch this exception when an update-class Client call races with Flow close cleanup. Re-read the retained terminal Flow state before deciding whether another action is needed. For example:

io.superdurable.dex.WaitForStepCompletionOptions options =
        io.superdurable.dex.WaitForStepCompletionOptions.newBuilder()
                .requestTimeout(timeout)
                .build();
try {
    client.waitForStepCompletion(flowId, stepExecutionId, options);
} catch (FlowClosingException closing) {
    client.waitForFlow(flowId, timeout);
}

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FlowClosingException(io.grpc.Status.Code code, String detail, Throwable cause)	Creates a Flow-closing exception from a Dex service response.

Method Summary

Methods inherited from class DexServiceException

getCode, getDetail, getSubStatus

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

FlowClosingException

public FlowClosingException(io.grpc.Status.Code code,
 String detail,
 Throwable cause)

Creates a Flow-closing exception from a Dex service response.

Parameters:

code - the gRPC status code returned by Dex

detail - the server-provided close-cleanup detail

cause - the original transport failure