java.lang.Object
org.neo4j.driver.internal.retry.ExponentialBackoffRetryLogic
- All Implemented Interfaces:
RetryLogic
-
Nested Class Summary
-
Field Summary
-
Constructor Summary
ModifierConstructorDescriptionExponentialBackoffRetryLogic
(long maxTransactionRetryTime, io.netty.util.concurrent.EventExecutorGroup eventExecutorGroup, Clock clock, Logging logging) protected
ExponentialBackoffRetryLogic
(long maxTransactionRetryTime, io.netty.util.concurrent.EventExecutorGroup eventExecutorGroup, Clock clock, Logging logging, ExponentialBackoffRetryLogic.SleepTask sleepTask) -
Method Summary
Modifier and TypeMethodDescriptionprotected boolean
canRetryOn
(Throwable error) <T> T
<T> CompletionStage<T>
retryAsync
(Supplier<CompletionStage<T>> work) <T> org.reactivestreams.Publisher<T>
retryRx
(org.reactivestreams.Publisher<T> work)
-
Field Details
-
DEFAULT_MAX_RETRY_TIME_MS
public static final long DEFAULT_MAX_RETRY_TIME_MS
-
-
Constructor Details
-
ExponentialBackoffRetryLogic
-
ExponentialBackoffRetryLogic
protected ExponentialBackoffRetryLogic(long maxTransactionRetryTime, io.netty.util.concurrent.EventExecutorGroup eventExecutorGroup, Clock clock, Logging logging, ExponentialBackoffRetryLogic.SleepTask sleepTask)
-
-
Method Details
-
retry
- Specified by:
retry
in interfaceRetryLogic
-
retryAsync
- Specified by:
retryAsync
in interfaceRetryLogic
-
retryRx
public <T> org.reactivestreams.Publisher<T> retryRx(org.reactivestreams.Publisher<T> work) - Specified by:
retryRx
in interfaceRetryLogic
-
canRetryOn
-