From df469cc3ade94959096024ca016f71cb20c9f4e9 Mon Sep 17 00:00:00 2001 From: shikong <919411476@qq.com> Date: Mon, 18 Sep 2023 15:02:02 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8E=A8=E6=B5=81=E7=BB=93=E6=9D=9F=20?= =?UTF-8?q?=E5=8F=91=E9=80=81=E5=AA=92=E4=BD=93=E9=80=9A=E7=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../gb28181/mocking/service/device/DeviceProxyService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 afb314b..1b2ecec 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 @@ -65,7 +65,7 @@ public class DeviceProxyService { }); Flow.Subscriber subscriber = byeSubscriber(key, device, callbackTask); subscribe.getByeSubscribe().addSubscribe(key, subscriber); - callbackTask.put(device.getDeviceCode(), pushRtpTask(fromUrl, toUrl, time + 60)); + callbackTask.put(device.getDeviceCode(), pushRtpTask(fromUrl, toUrl, time + 60, mediaStatus(request, device, key))); scheduledExecutorService.schedule(subscriber::onComplete, time + 60, TimeUnit.SECONDS); }; }