org.apache.beam.sdk.io.solace

Class RetryCallableManager

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

@Internal
public abstract class RetryCallableManager
extends java.lang.Object
implements java.io.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 and Description
static class	RetryCallableManager.Builder

Constructor Summary

Constructors

Constructor and Description
RetryCallableManager()

Method Summary

Modifier and Type	Method and Description
static RetryCallableManager.Builder	builder()
static RetryCallableManager	create() Creates a new RetryCallableManager with default retry settings.
<V> V	retryCallable(java.util.concurrent.Callable<V> callable, java.util.Set<java.lang.Class<? extends java.lang.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 Detail

RetryCallableManager

public RetryCallableManager()

Method Detail

create

public static RetryCallableManager create()

Creates a new RetryCallableManager with default retry settings.

retryCallable

public <V> V retryCallable(java.util.concurrent.Callable<V> callable,
                           java.util.Set<java.lang.Class<? extends java.lang.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()