diff --git a/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/wvp/WvpService.java b/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/wvp/WvpService.java index 1660c8e..d02ca21 100644 --- a/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/wvp/WvpService.java +++ b/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/wvp/WvpService.java @@ -80,7 +80,7 @@ public class WvpService { .withWaitStrategy(WaitStrategies.fixedWait(DEFAULT_RETRY_WAIT_TIME, TimeUnit.SECONDS)) // 重试次数 .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)) .build(); } @@ -95,7 +95,7 @@ public class WvpService { .withWaitStrategy(WaitStrategies.fixedWait(DEFAULT_RETRY_WAIT_TIME, TimeUnit.SECONDS)) // 重试次数 .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)) .build(); }