Retry (reactor-core 3.4.1)

java.lang.Object
- reactor.util.retry.Retry

Direct Known Subclasses:

RetryBackoffSpec, RetrySpec
```
public abstract class Retry
extends Object
```
Base abstract class for a strategy to decide when to retry given a companion Flux of Retry.RetrySignal, for use with Flux.retryWhen(Retry) and Mono.retryWhen(Retry). Also provides access to configurable built-in strategies via static factory methods:
Users are encouraged to provide either concrete custom Retry strategies or builders that produce such concrete Retry. The RetrySpec returned by eg. max(long) is a good inspiration for a fluent approach that generates a Retry at each step and uses immutability/copy-on-write to enable sharing of intermediate steps (that can thus be considered templates).
Author:

Simon Baslé

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static interface Retry.RetrySignal
State for a Flux.retryWhen(Retry) Flux retry} or Mono retry.

Nested Classes
Modifier and Type	Class and Description
`static interface`	`Retry.RetrySignal` State for a `Flux.retryWhen(Retry)` Flux retry} or `Mono retry`.

Field Summary

Fields
Modifier and Type Field and Description

ContextView retryContext

Fields
Modifier and Type	Field and Description
`ContextView`	`retryContext`

Constructor Summary

Constructors
Modifier Constructor and Description

Retry()

protected Retry(ContextView retryContext)

Constructors
Modifier	Constructor and Description
	`Retry()`
`protected`	`Retry(ContextView retryContext)`

Method Summary

All Methods Static Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`static RetryBackoffSpec`	`backoff(long maxAttempts, Duration minBackoff)` A `RetryBackoffSpec` preconfigured for exponential backoff strategy with jitter, given a maximum number of retry attempts and a minimum `Duration` for the backoff.
`static RetryBackoffSpec`	`fixedDelay(long maxAttempts, Duration fixedDelay)` A `RetryBackoffSpec` preconfigured for fixed delays (min backoff equals max backoff, no jitter), given a maximum number of retry attempts and the fixed `Duration` for the backoff.
`static Retry`	`from(Function<Flux<Retry.RetrySignal>,? extends Publisher<?>> function)` A wrapper around `Function` to provide `Retry` by using lambda expressions.
`abstract Publisher<?>`	`generateCompanion(Flux<Retry.RetrySignal> retrySignals)` The intent of the functional `Retry` class is to let users configure how to react to `Retry.RetrySignal` by providing the operator with a companion publisher.
`static RetrySpec`	`indefinitely()` A `RetrySpec` preconfigured for the most simplistic retry strategy: retry immediately and indefinitely (similar to `Flux.retry()`).
`static RetrySpec`	`max(long max)` A `RetrySpec` preconfigured for a simple strategy with maximum number of retry attempts.
`static RetrySpec`	`maxInARow(long maxInARow)` A `RetrySpec` preconfigured for a simple strategy with maximum number of retry attempts over subsequent transient errors.
`ContextView`	`retryContext()` Return the user provided context that was set at construction time.
`static Retry`	`withThrowable(Function<Flux<Throwable>,? extends Publisher<?>> function)` An adapter for `Flux` of `Throwable`-based `Function` to provide `Retry` from a legacy retryWhen `Function`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - retryContext
```
public final ContextView retryContext
```
- Constructor Detail
  - Retry
```
public Retry()
```
  - Retry
```
protected Retry(ContextView retryContext)
```
- Method Detail
  - generateCompanion
```
public abstract Publisher<?> generateCompanion(Flux<Retry.RetrySignal> retrySignals)
```
    The intent of the functional Retry class is to let users configure how to react to Retry.RetrySignal by providing the operator with a companion publisher. Any onNext emitted by this publisher will trigger a retry, but if that emission is delayed compared to the original signal then the attempt is delayed as well. This method generates the companion, out of a Flux of Retry.RetrySignal, which itself can serve as the simplest form of retry companion (indefinitely and immediately retry on any error).
    
    Parameters:
    
    retrySignals - the original Flux of Retry.RetrySignal, notifying of each source error that might result in a retry attempt, with context around the error and current retry cycle.
    
    Returns:
    
    the actual companion to use, which might delay or limit retry attempts
  - retryContext
```
public ContextView retryContext()
```
    Return the user provided context that was set at construction time.
    
    Returns:
    
    the user provided context that will be accessible via Retry.RetrySignal.retryContextView().
  - backoff
```
public static RetryBackoffSpec backoff(long maxAttempts,
                                       Duration minBackoff)
```
    A RetryBackoffSpec preconfigured for exponential backoff strategy with jitter, given a maximum number of retry attempts and a minimum Duration for the backoff.
    
    Parameters:
    
    maxAttempts - the maximum number of retry attempts to allow
    
    minBackoff - the minimum Duration for the first backoff
    
    Returns:
    
    the exponential backoff spec for further configuration
    
    See Also:
    
    RetryBackoffSpec.maxAttempts(long), RetryBackoffSpec.minBackoff(Duration)
  - fixedDelay
```
public static RetryBackoffSpec fixedDelay(long maxAttempts,
                                          Duration fixedDelay)
```
    A RetryBackoffSpec preconfigured for fixed delays (min backoff equals max backoff, no jitter), given a maximum number of retry attempts and the fixed Duration for the backoff.
    
    Note that calling RetryBackoffSpec.minBackoff(Duration) or RetryBackoffSpec.maxBackoff(Duration) would switch back to an exponential backoff strategy.
    
    Parameters:
    
    maxAttempts - the maximum number of retry attempts to allow
    
    fixedDelay - the Duration of the fixed delays
    
    Returns:
    
    the fixed delays spec for further configuration
    
    See Also:
    
    RetryBackoffSpec.maxAttempts(long), RetryBackoffSpec.minBackoff(Duration), RetryBackoffSpec.maxBackoff(Duration)
  - max
```
public static RetrySpec max(long max)
```
    A RetrySpec preconfigured for a simple strategy with maximum number of retry attempts.
    
    Parameters:
    
    max - the maximum number of retry attempts to allow
    
    Returns:
    
    the max attempt spec for further configuration
    
    See Also:
    
    RetrySpec.maxAttempts(long)
  - maxInARow
```
public static RetrySpec maxInARow(long maxInARow)
```
    A RetrySpec preconfigured for a simple strategy with maximum number of retry attempts over subsequent transient errors. An Subscriber.onNext(Object) between errors resets the counter (see RetrySpec.transientErrors(boolean)).
    
    Parameters:
    
    maxInARow - the maximum number of retry attempts to allow in a row, reset by successful onNext
    
    Returns:
    
    the max in a row spec for further configuration
    
    See Also:
    
    RetrySpec.maxAttempts(long), RetrySpec.transientErrors(boolean)
  - indefinitely
```
public static RetrySpec indefinitely()
```
    A RetrySpec preconfigured for the most simplistic retry strategy: retry immediately and indefinitely (similar to Flux.retry()).
    
    Returns:
    
    the retry indefinitely spec for further configuration
  - from
```
public static final Retry from(Function<Flux<Retry.RetrySignal>,? extends Publisher<?>> function)
```
    A wrapper around Function to provide Retry by using lambda expressions.
    
    Parameters:
    
    function - the Function representing the desired Retry strategy as a lambda
    
    Returns:
    
    the Retry strategy adapted from the Function
  - withThrowable
```
public static final Retry withThrowable(Function<Flux<Throwable>,? extends Publisher<?>> function)
```
    An adapter for Flux of Throwable-based Function to provide Retry from a legacy retryWhen Function.
    
    Parameters:
    
    function - the Function representing the desired Retry strategy as a lambda
    
    Returns:
    
    the Retry strategy adapted from the Function

Class Retry

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

retryContext

Constructor Detail

Retry

Retry

Method Detail

generateCompanion

retryContext

backoff

fixedDelay

max

maxInARow

indefinitely

from

withThrowable