diff --git a/gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/device/DeviceProxyService.java b/gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/device/DeviceProxyService.java index ec21621..9c83b47 100644 --- a/gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/device/DeviceProxyService.java +++ b/gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/device/DeviceProxyService.java @@ -95,7 +95,7 @@ public class DeviceProxyService { boolean tcp = StringUtils.containsIgnoreCase(mediaDescription.getMedia().getProtocol(), "TCP"); zlmStreamChangeHookService.getRegistHandler().put(callId,()->{ Retryer retryer = RetryerBuilder.newBuilder() - .retryIfResult(resp -> resp.getLocalPort() == null) + .retryIfResult(resp -> resp.getLocalPort() == null || resp.getLocalPort() <= 0) .retryIfException() .retryIfRuntimeException() // 重试间隔 @@ -153,7 +153,7 @@ public class DeviceProxyService { boolean tcp = StringUtils.containsIgnoreCase(mediaDescription.getMedia().getProtocol(), "TCP"); zlmStreamChangeHookService.getRegistHandler().put(callId,()->{ Retryer retryer = RetryerBuilder.newBuilder() - .retryIfResult(resp -> resp.getLocalPort() == null) + .retryIfResult(resp -> resp.getLocalPort() == null || resp.getLocalPort() <= 0) .retryIfException() .retryIfRuntimeException() // 重试间隔