From 26d279a04c699a5ab3d4ea030cb40d8c7d916100 Mon Sep 17 00:00:00 2001 From: shikong <919411476@qq.com> Date: Sun, 8 Oct 2023 13:13:38 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=8E=A8=E6=B5=81=E9=87=8D?= =?UTF-8?q?=E8=AF=95=20=E6=9C=80=E5=A4=9A=E6=89=A7=E8=A1=8C=203=E6=AC=A1?= =?UTF-8?q?=20=E6=AF=8F=E6=AC=A1=E9=97=B4=E9=9A=943=E7=A7=92?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../gb28181/mocking/service/device/DeviceProxyService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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() // 重试间隔