Shikong/gb28181-docking-platform-mocking
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

zlmStreamRegistHookEvent 调整

Browse Source
This commit is contained in:
shikong 2024-03-14 09:15:49 +08:00
parent 0fd058e1c5
commit 7b350e899b
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/device/DeviceProxyService.java
View File

@ -170,18 +170,18 @@ public class DeviceProxyService {
log.info("结束 zlm rtp 推流, app {}, stream {}, ssrc {}", app, callId, ssrc); log.info("结束 zlm rtp 推流, app {}, stream {}, ssrc {}", app, callId, ssrc);
zlmMediaService.stopSendRtp(stopSendRtp); zlmMediaService.stopSendRtp(stopSendRtp);
}, 5, TimeUnit.SECONDS); }, 10, TimeUnit.SECONDS);
// 如果 流 在 5秒内 重新注册, 则 取消停止RTP推流 // 如果 流 在 10秒内 重新注册, 则 取消停止RTP推流
zlmStreamChangeHookService.getRegistHandler(app).put(callId,()->{ zlmStreamChangeHookService.getRegistHandler(app).put(callId,()->{
schedule.cancel(true); schedule.cancel(true);
zlmStreamRegistHookEvent(app, callId, ssrc); zlmStreamRegistHookEvent(app, callId, ssrc);
}); });
// 如果 注销 后 5.5 秒内 没有再注册, 就彻底取消相关事件的订阅 // 如果 注销 后 10.5 秒内 没有再注册, 就彻底取消相关事件的订阅
scheduledExecutorService.schedule(()->{ scheduledExecutorService.schedule(()->{
zlmStreamChangeHookService.getRegistHandler(app).remove(callId); zlmStreamChangeHookService.getRegistHandler(app).remove(callId);
},5500, TimeUnit.MILLISECONDS); },10500, TimeUnit.MILLISECONDS);
}); });
}); });
} }