From 28dfe97a5ad2a4ea359e190480c89e82aa18ec7d Mon Sep 17 00:00:00 2001
From: shikong <919411476@qq.com>
Date: Thu, 14 Mar 2024 10:45:15 +0800
Subject: [PATCH] =?UTF-8?q?DeviceProxyService=20=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mocking/service/device/DeviceProxyService.java       | 9 +++++++--
 1 file changed, 7 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 b7fb934..4f54944 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
@@ -241,7 +241,12 @@ public class DeviceProxyService {
 
     public TaskProcessor downloadTask(){
         return (Runnable sendOkResponse,SIPRequest request,String callId,String fromUrl, String toAddr,int toPort, MockingDevice device, String key, long time,String ssrc)->{
-            scheduledExecutorService.schedule(() -> {
+            try {
+                TimeUnit.SECONDS.sleep(1);
+            } catch (InterruptedException e) {
+                log.error("{}", e.getMessage());
+            }
+
                 trying(request);
                 sendOkResponse.run();
                 String ackKey = GenericSubscribe.Helper.getKey(Request.ACK, callId);
@@ -292,7 +297,7 @@ public class DeviceProxyService {
                         }
                     }
                 });
-            }, 1, TimeUnit.SECONDS);
+
         };
     }