Shikong/gb28181-docking-platform-proxy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修复重试逻辑

Browse Source
This commit is contained in:
shikong 2023-09-09 23:03:54 +08:00
parent 62cd5e2016
commit ef6c164c0f
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/wvp/WvpService.java
View File

@ -80,7 +80,7 @@ public class WvpService {
.withWaitStrategy(WaitStrategies.fixedWait(DEFAULT_RETRY_WAIT_TIME, TimeUnit.SECONDS)) .withWaitStrategy(WaitStrategies.fixedWait(DEFAULT_RETRY_WAIT_TIME, TimeUnit.SECONDS))
// 重试次数 // 重试次数
.withStopStrategy(StopStrategies.stopAfterAttempt(DEFAULT_RETRY_TIME)) .withStopStrategy(StopStrategies.stopAfterAttempt(DEFAULT_RETRY_TIME))
.retryIfResult(result -> result != null && (result.getCode() != 0 || result.getCode() != 200)) .retryIfResult(result -> result == null || (result.getCode() != 0 && result.getCode() != 200))
.withRetryListener(defaultRetryListener(name)) .withRetryListener(defaultRetryListener(name))
.build(); .build();
} }
@ -95,7 +95,7 @@ public class WvpService {
.withWaitStrategy(WaitStrategies.fixedWait(DEFAULT_RETRY_WAIT_TIME, TimeUnit.SECONDS)) .withWaitStrategy(WaitStrategies.fixedWait(DEFAULT_RETRY_WAIT_TIME, TimeUnit.SECONDS))
// 重试次数 // 重试次数
.withStopStrategy(StopStrategies.stopAfterAttempt(DEFAULT_RETRY_TIME)) .withStopStrategy(StopStrategies.stopAfterAttempt(DEFAULT_RETRY_TIME))
.retryIfResult(result -> result != null && (result.getCode() != 0 || result.getCode() != 200)) .retryIfResult(result -> result == null || (result.getCode() != 0 && result.getCode() != 200))
.withRetryListener(defaultRetryListener(name)) .withRetryListener(defaultRetryListener(name))
.build(); .build();
} }