Module org.neo4j.driver

Package org.neo4j.driver.internal.retry

Class ExponentialBackoffRetryLogic

java.lang.Object

org.neo4j.driver.internal.retry.ExponentialBackoffRetryLogic

All Implemented Interfaces:

RetryLogic

public class ExponentialBackoffRetryLogic
extends Object
implements RetryLogic

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ExponentialBackoffRetryLogic.SleepTask

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_MAX_RETRY_TIME_MS

Constructor Summary

Constructors

Modifier	Constructor	Description
	ExponentialBackoffRetryLogic(long maxTransactionRetryTime, ScheduledExecutorService executor, Clock clock, Logging logging)
protected	ExponentialBackoffRetryLogic(long maxTransactionRetryTime, ScheduledExecutorService executor, Clock clock, Logging logging, ExponentialBackoffRetryLogic.SleepTask sleepTask)

Method Summary

Modifier and Type	Method	Description
protected boolean	canRetryOn(Throwable error)
<T> T	retry(Supplier<T> work)
<T> CompletionStage<T>	retryAsync(Supplier<CompletionStage<T>> work)
<T> org.reactivestreams.Publisher<T>	retryRx(org.reactivestreams.Publisher<T> work)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_MAX_RETRY_TIME_MS

public static final long DEFAULT_MAX_RETRY_TIME_MS

Constructor Details

ExponentialBackoffRetryLogic

public ExponentialBackoffRetryLogic(long maxTransactionRetryTime,
 ScheduledExecutorService executor,
 Clock clock,
 Logging logging)

ExponentialBackoffRetryLogic

protected ExponentialBackoffRetryLogic(long maxTransactionRetryTime,
 ScheduledExecutorService executor,
 Clock clock,
 Logging logging,
 ExponentialBackoffRetryLogic.SleepTask sleepTask)

Method Details

retry

public <T> T retry(Supplier<T> work)

Specified by:

retry in interface RetryLogic

retryAsync

public <T> CompletionStage<T> retryAsync(Supplier<CompletionStage<T>> work)

Specified by:

retryAsync in interface RetryLogic

retryRx

public <T> org.reactivestreams.Publisher<T> retryRx(org.reactivestreams.Publisher<T> work)

Specified by:

retryRx in interface RetryLogic

canRetryOn

protected boolean canRetryOn(Throwable error)