reactor.retry

Class DefaultContext<T>

java.lang.Object

reactor.retry.DefaultContext<T>

All Implemented Interfaces:

Context<T>, RepeatContext<T>, RetryContext<T>

public class DefaultContext<T>
extends java.lang.Object
implements RetryContext<T>, RepeatContext<T>

Constructor Summary

Constructors

Constructor and Description
DefaultContext(T applicationContext, long iteration, BackoffDelay backoff, long repeatCompanionValue)
DefaultContext(T applicationContext, long iteration, BackoffDelay backoff, java.lang.Throwable exception)

Method Summary

Modifier and Type	Method and Description
T	applicationContext() Application context that may be used to perform any rollbacks before a retry.
java.time.Duration	backoff() The backoff delay.
java.lang.Long	companionValue() Returns the value provided in the companion Flux for repeats.
java.lang.Throwable	exception() Returns the exception from the last iteration.
long	iteration() The next iteration number.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultContext

public DefaultContext(T applicationContext,
                      long iteration,
                      BackoffDelay backoff,
                      long repeatCompanionValue)

DefaultContext

public DefaultContext(T applicationContext,
                      long iteration,
                      BackoffDelay backoff,
                      java.lang.Throwable exception)

Method Detail

applicationContext

public T applicationContext()

Description copied from interface: Context

Application context that may be used to perform any rollbacks before a retry. Application context can be configured using Retry.withApplicationContext(Object) or Repeat.withApplicationContext(Object).

Specified by:

applicationContext in interface Context<T>

Returns:

application context

iteration

public long iteration()

Description copied from interface: Context

The next iteration number. This is a zero-based incrementing number with the first attempt prior to any retries as iteration zero.

Specified by:

iteration in interface Context<T>

Returns:

the current iteration number

companionValue

public java.lang.Long companionValue()

Description copied from interface: RepeatContext

Returns the value provided in the companion Flux for repeats.

• For Flux.repeatWhen(java.util.function.Function) and Mono.repeatWhen(java.util.function.Function), value is the number of items emitted in the last attempt.
• For Mono.repeatWhenEmpty(java.util.function.Function) and Mono.repeatWhenEmpty(int, java.util.function.Function), value is a zero-based incrementing Long, which is number of attempts - 1.

Specified by:

companionValue in interface RepeatContext<T>

Returns:

value the value emitted on the companion Flux for repeats.

exception

public java.lang.Throwable exception()

Description copied from interface: RetryContext

Returns the exception from the last iteration.

Specified by:

exception in interface RetryContext<T>

Returns:

exception that resulted in retry

backoff

public java.time.Duration backoff()

Description copied from interface: Context

The backoff delay. When Backoff function is invoked, the previous backoff is provided in the context. The context provided for the retry predicates Retry.onlyIf(java.util.function.Predicate) and Repeat.onlyIf(java.util.function.Predicate) as well as the retry callbacks Retry.doOnRetry(java.util.function.Consumer) and Repeat.doOnRepeat(java.util.function.Consumer) provide the backoff delay for the next retry.

Specified by:

backoff in interface Context<T>

Returns:

Backoff delay

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object