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>, net.thevpc.nuts.concurrent.NCallable<T>, net.thevpc.nuts.concurrent.NRetryCall<T>, net.thevpc.nuts.elem.NDescribable, net.thevpc.nuts.elem.NRedescribable<net.thevpc.nuts.concurrent.NCallable<T>>

public class NRetryCallImpl<T>
extends Object
implements net.thevpc.nuts.concurrent.NRetryCall<T>

Nested Class Summary

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

net.thevpc.nuts.concurrent.NRetryCall.Handler<T>, net.thevpc.nuts.concurrent.NRetryCall.Result<T>, net.thevpc.nuts.concurrent.NRetryCall.Status

Constructor Summary

Constructors

Constructor and Description
NRetryCallImpl(String id, net.thevpc.nuts.concurrent.NCallable<T> callable, net.thevpc.nuts.concurrent.NRetryCallStore store)

Method Summary

Modifier and Type	Method and Description
T	call()
void	callAsync()
Future<net.thevpc.nuts.concurrent.NRetryCall.Result<T>>	callFuture()
T	callOrElse(net.thevpc.nuts.concurrent.NCallable<T> recover)
net.thevpc.nuts.concurrent.NRetryCall<T>	exponentialRetryPeriod(net.thevpc.nuts.time.NDuration basePeriod, double multiplier)
net.thevpc.nuts.concurrent.NRetryCall<T>	handler(net.thevpc.nuts.concurrent.NRetryCall.Handler<T> handler)
net.thevpc.nuts.concurrent.NRetryCall<T>	maxRetries(int maxRetries)
net.thevpc.nuts.concurrent.NRetryCall<T>	multipliedRetryPeriod(net.thevpc.nuts.time.NDuration basePeriod, double multiplier)
net.thevpc.nuts.concurrent.NRetryCall<T>	recover(net.thevpc.nuts.concurrent.NCallable<T> recover)
void	reload()
net.thevpc.nuts.concurrent.NRetryCall<T>	retryPeriod(IntFunction<net.thevpc.nuts.time.NDuration> retryPeriod)
net.thevpc.nuts.concurrent.NRetryCall<T>	retryPeriod(net.thevpc.nuts.time.NDuration period)
net.thevpc.nuts.concurrent.NRetryCall<T>	retryPeriods(net.thevpc.nuts.time.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,
                      net.thevpc.nuts.concurrent.NCallable<T> callable,
                      net.thevpc.nuts.concurrent.NRetryCallStore store)

Method Detail

reload

public void reload()

maxRetries

public net.thevpc.nuts.concurrent.NRetryCall<T> maxRetries(int maxRetries)

Specified by:

maxRetries in interface net.thevpc.nuts.concurrent.NRetryCall<T>

multipliedRetryPeriod

public net.thevpc.nuts.concurrent.NRetryCall<T> multipliedRetryPeriod(net.thevpc.nuts.time.NDuration basePeriod,
                                                                      double multiplier)

Specified by:

multipliedRetryPeriod in interface net.thevpc.nuts.concurrent.NRetryCall<T>

exponentialRetryPeriod

public net.thevpc.nuts.concurrent.NRetryCall<T> exponentialRetryPeriod(net.thevpc.nuts.time.NDuration basePeriod,
                                                                       double multiplier)

Specified by:

exponentialRetryPeriod in interface net.thevpc.nuts.concurrent.NRetryCall<T>

retryPeriod

public net.thevpc.nuts.concurrent.NRetryCall<T> retryPeriod(net.thevpc.nuts.time.NDuration period)

Specified by:

retryPeriod in interface net.thevpc.nuts.concurrent.NRetryCall<T>

retryPeriods

public net.thevpc.nuts.concurrent.NRetryCall<T> retryPeriods(net.thevpc.nuts.time.NDuration... periods)

Specified by:

retryPeriods in interface net.thevpc.nuts.concurrent.NRetryCall<T>

retryPeriod

public net.thevpc.nuts.concurrent.NRetryCall<T> retryPeriod(IntFunction<net.thevpc.nuts.time.NDuration> retryPeriod)

Specified by:

retryPeriod in interface net.thevpc.nuts.concurrent.NRetryCall<T>

recover

public net.thevpc.nuts.concurrent.NRetryCall<T> recover(net.thevpc.nuts.concurrent.NCallable<T> recover)

Specified by:

recover in interface net.thevpc.nuts.concurrent.NRetryCall<T>

handler

public net.thevpc.nuts.concurrent.NRetryCall<T> handler(net.thevpc.nuts.concurrent.NRetryCall.Handler<T> handler)

Specified by:

handler in interface net.thevpc.nuts.concurrent.NRetryCall<T>

callOrElse

public T callOrElse(net.thevpc.nuts.concurrent.NCallable<T> recover)

Specified by:

callOrElse in interface net.thevpc.nuts.concurrent.NRetryCall<T>

call

public T call()

Specified by:

call in interface Callable<T>

Specified by:

call in interface net.thevpc.nuts.concurrent.NCallable<T>

Specified by:

call in interface net.thevpc.nuts.concurrent.NRetryCall<T>

callAsync

public void callAsync()

Specified by:

callAsync in interface net.thevpc.nuts.concurrent.NRetryCall<T>

callFuture

public Future<net.thevpc.nuts.concurrent.NRetryCall.Result<T>> callFuture()

Specified by:

callFuture in interface net.thevpc.nuts.concurrent.NRetryCall<T>