GTsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 2.0.0

Browse Source 
1. 修复不重试问题
This commit is contained in:
byteblogs168 2023-06-21 08:58:03 +08:00
parent 8dcd58a3dc
commit 61bf6049e2
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/executor/GuavaRetryExecutor.java
View File

@ -4,8 +4,13 @@ import cn.hutool.core.lang.Assert;
import com.aizuda.easy.retry.client.core.RetryExecutorParameter;
import com.aizuda.easy.retry.client.core.cache.RetryerInfoCache;
import com.aizuda.easy.retry.client.core.exception.EasyRetryClientException;
import com.github.rholder.retry.*;
import com.aizuda.easy.retry.common.core.log.LogUtils;
import com.github.rholder.retry.RetryException;
import com.github.rholder.retry.RetryListener;
import com.github.rholder.retry.Retryer;
import com.github.rholder.retry.RetryerBuilder;
import com.github.rholder.retry.StopStrategy;
import com.github.rholder.retry.WaitStrategy;
import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.Callable;
@ -33,6 +38,7 @@ public class GuavaRetryExecutor extends AbstractRetryExecutor<WaitStrategy, Stop
public Retryer build(RetryExecutorParameter<WaitStrategy, StopStrategy> parameter) {
RetryerBuilder<Object> retryerBuilder = RetryerBuilder.newBuilder();
retryerBuilder.retryIfException(throwable -> true);
retryerBuilder.withWaitStrategy(parameter.backOff());
retryerBuilder.withStopStrategy(parameter.stop());
for (RetryListener retryListener : parameter.getRetryListeners()) {