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

调整

Browse Source
This commit is contained in:
shikong 2024-03-17 00:32:33 +08:00
parent d0803c6b62
commit d01d76304b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -136,8 +136,8 @@ public class DeviceProxyService {
zlmPublishHookService.getHandler(DEFAULT_ZLM_APP).put(callId,()->{ zlmPublishHookService.getHandler(DEFAULT_ZLM_APP).put(callId,()->{
executor.execute(()->{ executor.execute(()->{
try { try {
StartSendRtpResp sendRtpResp = retryer.call(() -> {
StartSendRtp startSendRtp = new StartSendRtp(); StartSendRtp startSendRtp = new StartSendRtp();
StartSendRtpResp sendRtpResp = retryer.call(() -> {
startSendRtp.setApp(DEFAULT_ZLM_APP); startSendRtp.setApp(DEFAULT_ZLM_APP);
startSendRtp.setStream(callId); startSendRtp.setStream(callId);
startSendRtp.setSsrc(ssrc); startSendRtp.setSsrc(ssrc);
@ -150,7 +150,7 @@ public class DeviceProxyService {
return startSendRtpResp; return startSendRtpResp;
}); });
log.info("sendRtp 推流成功 {} {}, {}", device.getDeviceCode(),device.getGbChannelId(), sendRtpResp); log.info("sendRtp 推流成功 {} {}, req => {}, resp => {}", device.getDeviceCode(),device.getGbChannelId(), startSendRtp, sendRtpResp);
} catch (Exception e) { } catch (Exception e) {
log.error("zlm rtp 推流失败, {} {} {}, {}", device.getDeviceCode(),device.getGbChannelId(), callId, e.getMessage()); log.error("zlm rtp 推流失败, {} {} {}, {}", device.getDeviceCode(),device.getGbChannelId(), callId, e.getMessage());
Optional.ofNullable(zlmStreamChangeHookService.getUnregistHandler(DEFAULT_ZLM_APP).remove(callId)) Optional.ofNullable(zlmStreamChangeHookService.getUnregistHandler(DEFAULT_ZLM_APP).remove(callId))