Package org.apache.beam.sdk.io.solace

Class RetryCallableManager

java.lang.Object

org.apache.beam.sdk.io.solace.RetryCallableManager

All Implemented Interfaces:

Serializable

@Internal
public abstract class RetryCallableManager
extends Object
implements Serializable

A class that manages retrying of callables based on the exceptions they throw.

This class provides a way to retry a callable if it throws an exception. The retry behavior is configurable using RetrySettings.

This class is internal and should not be used directly.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RetryCallableManager.Builder

Constructor Summary

Constructors

Constructor	Description
RetryCallableManager()

Method Summary

Modifier and Type	Method	Description
static RetryCallableManager.Builder	builder()
static RetryCallableManager	create()	Creates a new RetryCallableManager with default retry settings.
<V> V	retryCallable(Callable<V> callable, Set<Class<? extends Exception>> exceptionsToIntercept)	Method that executes and repeats the execution of the callable argument, if it throws one of the exceptions from the exceptionsToIntercept Set.

Methods inherited from class java.lang.Object

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

Constructor Details

RetryCallableManager

public RetryCallableManager()

Method Details

create

public static RetryCallableManager create()

Creates a new RetryCallableManager with default retry settings.

retryCallable

public <V> V retryCallable(Callable<V> callable,
 Set<Class<? extends Exception>> exceptionsToIntercept)

Method that executes and repeats the execution of the callable argument, if it throws one of the exceptions from the exceptionsToIntercept Set.

Type Parameters:

V - The type of the callable's return value.

Parameters:

callable - The callable to execute.

exceptionsToIntercept - The set of exceptions to intercept.

Returns:

The return value of the callable.

builder

public static RetryCallableManager.Builder builder()