net.thevpc.nuts.runtime.standalone.concurrent

Class NRetryCallImpl<T>

java.lang.Object

net.thevpc.nuts.runtime.standalone.concurrent.NRetryCallImpl<T>

All Implemented Interfaces:

Callable<T>, NCallable<T>, NRetryCall<T>, NDescribable, NRedescribable<NCallable<T>>

public class NRetryCallImpl<T>
extends Object
implements NRetryCall<T>

Nested Class Summary

Nested classes/interfaces inherited from interface net.thevpc.nuts.concurrent.NRetryCall

NRetryCall.Handler<T>, NRetryCall.Result<T>, NRetryCall.Status

Constructor Summary

Constructors

Constructor and Description
NRetryCallImpl(String id, NCallable<T> callable, NRetryCallStore store)

Method Summary

Modifier and Type	Method and Description
T	call()
void	callAsync()
Future<NRetryCall.Result<T>>	callFuture()
T	callOrElse(NCallable<T> recover)
NRetryCall<T>	exponentialRetryPeriod(NDuration basePeriod, double multiplier)
NRetryCall<T>	handler(NRetryCall.Handler<T> handler)
NRetryCall<T>	maxRetries(int maxRetries)
NRetryCall<T>	multipliedRetryPeriod(NDuration basePeriod, double multiplier)
NRetryCall<T>	recover(NCallable<T> recover)
void	reload()
NRetryCall<T>	retryPeriod(IntFunction<NDuration> retryPeriod)
NRetryCall<T>	retryPeriod(NDuration period)
NRetryCall<T>	retryPeriods(NDuration... periods)

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.thevpc.nuts.concurrent.NRetryCall

of, of

Methods inherited from interface net.thevpc.nuts.concurrent.NCallable

of, withDescription

Methods inherited from interface net.thevpc.nuts.elem.NDescribable

describe

Constructor Detail

NRetryCallImpl

public NRetryCallImpl(String id,
                      NCallable<T> callable,
                      NRetryCallStore store)

Method Detail

reload

public void reload()

maxRetries

public NRetryCall<T> maxRetries(int maxRetries)

Specified by:

maxRetries in interface NRetryCall<T>

multipliedRetryPeriod

public NRetryCall<T> multipliedRetryPeriod(NDuration basePeriod,
                                           double multiplier)

Specified by:

multipliedRetryPeriod in interface NRetryCall<T>

exponentialRetryPeriod

public NRetryCall<T> exponentialRetryPeriod(NDuration basePeriod,
                                            double multiplier)

Specified by:

exponentialRetryPeriod in interface NRetryCall<T>

retryPeriod

public NRetryCall<T> retryPeriod(NDuration period)

Specified by:

retryPeriod in interface NRetryCall<T>

retryPeriods

public NRetryCall<T> retryPeriods(NDuration... periods)

Specified by:

retryPeriods in interface NRetryCall<T>

retryPeriod

public NRetryCall<T> retryPeriod(IntFunction<NDuration> retryPeriod)

Specified by:

retryPeriod in interface NRetryCall<T>

recover

public NRetryCall<T> recover(NCallable<T> recover)

Specified by:

recover in interface NRetryCall<T>

handler

public NRetryCall<T> handler(NRetryCall.Handler<T> handler)

Specified by:

handler in interface NRetryCall<T>

callOrElse

public T callOrElse(NCallable<T> recover)

Specified by:

callOrElse in interface NRetryCall<T>

call

public T call()

Specified by:

call in interface Callable<T>

Specified by:

call in interface NCallable<T>

Specified by:

call in interface NRetryCall<T>

callAsync

public void callAsync()

Specified by:

callAsync in interface NRetryCall<T>

callFuture

public Future<NRetryCall.Result<T>> callFuture()

Specified by:

callFuture in interface NRetryCall<T>