程序包 com.aizuda.easy.retry.client.core.strategy

类 AbstractRetryStrategies

java.lang.Object

com.aizuda.easy.retry.client.core.strategy.AbstractRetryStrategies

所有已实现的接口:

RetryStrategy

直接已知子类:

LocalRetryStrategies, ManualRetryStrategies, RemoteRetryStrategies

public abstract class AbstractRetryStrategies
extends Object
implements RetryStrategy

构造器概要

构造器

构造器	说明
AbstractRetryStrategies()

方法概要

修饰符和类型	方法	说明
protected abstract Callable	doGetCallable(RetryExecutor<com.github.rholder.retry.WaitStrategy,com.github.rholder.retry.StopStrategy> retryExecutor, Object[] params)
protected abstract Consumer<Throwable>	doGetRetryErrorConsumer(RetryerInfo retryerInfo, Object[] params)
protected boolean	doReport(RetryerInfo retryerInfo, Object[] params)	上报数据
protected abstract Consumer<Object>	doRetrySuccessConsumer(RetryerResultContext context)
protected abstract void	error(RetryerResultContext context)
protected abstract RetryExecutorParameter<com.github.rholder.retry.WaitStrategy,com.github.rholder.retry.StopStrategy>	getRetryExecutorParameter(RetryerInfo retryerInfo)
protected Consumer<Object>	getRetrySuccessConsumer(RetryerResultContext retryerResultContext)
RetryerResultContext	openRetry(String sceneName, String executorClassName, Object[] params)
protected abstract boolean	preValidator(RetryerInfo retryerInfo, RetryerResultContext resultContext)
protected abstract void	setStage()
protected abstract void	success(RetryerResultContext retryerResultContext)
protected abstract void	unexpectedError(Exception e, RetryerResultContext retryerResultContext)

从类继承的方法 java.lang.Object

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

从接口继承的方法 com.aizuda.easy.retry.client.core.strategy.RetryStrategy

supports

构造器详细资料

AbstractRetryStrategies

public AbstractRetryStrategies()

方法详细资料

openRetry

public RetryerResultContext openRetry(String sceneName,
 String executorClassName,
 Object[] params)

指定者:

openRetry 在接口中 RetryStrategy

setStage

protected abstract void setStage()

getRetrySuccessConsumer

protected Consumer<Object> getRetrySuccessConsumer(RetryerResultContext retryerResultContext)

doRetrySuccessConsumer

protected abstract Consumer<Object> doRetrySuccessConsumer(RetryerResultContext context)

error

protected abstract void error(RetryerResultContext context)

preValidator

protected abstract boolean preValidator(RetryerInfo retryerInfo,
 RetryerResultContext resultContext)

unexpectedError

protected abstract void unexpectedError(Exception e,
 RetryerResultContext retryerResultContext)

success

protected abstract void success(RetryerResultContext retryerResultContext)

doGetRetryErrorConsumer

protected abstract Consumer<Throwable> doGetRetryErrorConsumer(RetryerInfo retryerInfo,
 Object[] params)

doGetCallable

protected abstract Callable doGetCallable(RetryExecutor<com.github.rholder.retry.WaitStrategy,com.github.rholder.retry.StopStrategy> retryExecutor,
 Object[] params)

getRetryExecutorParameter

protected abstract RetryExecutorParameter<com.github.rholder.retry.WaitStrategy,com.github.rholder.retry.StopStrategy> getRetryExecutorParameter(RetryerInfo retryerInfo)

doReport

protected boolean doReport(RetryerInfo retryerInfo,
 Object[] params)

上报数据

参数:

retryerInfo - 定义重试场景的信息

params - 执行参数