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)
void	reload()
NRetryCall<T>	setExponentialRetryPeriod(NDuration basePeriod, double multiplier)
NRetryCall<T>	setHandler(NRetryCall.Handler<T> handler)
NRetryCall<T>	setMaxRetries(int maxRetries)
NRetryCall<T>	setMultipliedRetryPeriod(NDuration basePeriod, double multiplier)
NRetryCall<T>	setRecover(NCallable<T> recover)
NRetryCall<T>	setRetryPeriod(IntFunction<NDuration> retryPeriod)
NRetryCall<T>	setRetryPeriod(NDuration period)
NRetryCall<T>	setRetryPeriods(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()

setMaxRetries

public NRetryCall<T> setMaxRetries(int maxRetries)

Specified by:

setMaxRetries in interface NRetryCall<T>

setMultipliedRetryPeriod

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

Specified by:

setMultipliedRetryPeriod in interface NRetryCall<T>

setExponentialRetryPeriod

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

Specified by:

setExponentialRetryPeriod in interface NRetryCall<T>

setRetryPeriod

public NRetryCall<T> setRetryPeriod(NDuration period)

Specified by:

setRetryPeriod in interface NRetryCall<T>

setRetryPeriods

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

Specified by:

setRetryPeriods in interface NRetryCall<T>

setRetryPeriod

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

Specified by:

setRetryPeriod in interface NRetryCall<T>

setRecover

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

Specified by:

setRecover in interface NRetryCall<T>

setHandler

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

Specified by:

setHandler 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>