Exception ServerStreamingAttemptException (2.11.0)

public class ServerStreamingAttemptException extends RuntimeException

A wrapper exception thrown by ServerStreamingAttemptCallable to communicate additional context to the StreamingRetryAlgorithm and to pass the original cancellation stack trace to RetryingServerStreamingCallable.

For internal use only - public for technical reasons.

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Throwable.addSuppressed(Throwable)

Throwable.fillInStackTrace()

Throwable.getCause()

Throwable.getLocalizedMessage()

Throwable.getMessage()

Throwable.getStackTrace()

Throwable.getSuppressed()

Throwable.initCause(Throwable)

Throwable.printStackTrace()

Throwable.printStackTrace(PrintStream)

Throwable.printStackTrace(PrintWriter)

Throwable.setStackTrace(StackTraceElement[])

Throwable.toString()

Constructors

ServerStreamingAttemptException(Throwable cause, boolean canResume, boolean seenResponses)

public ServerStreamingAttemptException(Throwable cause, boolean canResume, boolean seenResponses)

Parameters

Name	Description
cause	`Throwable`
canResume	`boolean`
seenResponses	`boolean`

Methods

canResume()

public boolean canResume()

If the StreamResumptionStrategy supports resuming after this error.

Returns

Type	Description
boolean

hasSeenResponses()

public boolean hasSeenResponses()

If the current RPC attempt has seen any streamed messages. This is used as a signal by StreamingRetryAlgorithm to reset timers.

Returns

Type	Description
boolean