This commit is contained in:
shikong 2024-02-07 11:39:38 +08:00
parent da03975bdf
commit 74de647004

View File

@ -157,11 +157,12 @@ public class DeviceProxyService {
stopSendRtp.setApp(DEFAULT_ZLM_APP); stopSendRtp.setApp(DEFAULT_ZLM_APP);
stopSendRtp.setStream(callId); stopSendRtp.setStream(callId);
stopSendRtp.setSsrc(ssrc); stopSendRtp.setSsrc(ssrc);
sendBye(request,device,key);
}, 5, TimeUnit.SECONDS); }, 5, TimeUnit.SECONDS);
}); });
zlmStreamNoneReaderHookService.getHandler(DEFAULT_ZLM_APP).put(callId,()->{ // zlmStreamNoneReaderHookService.getHandler(DEFAULT_ZLM_APP).put(callId,()->{
sendBye(request,device,key); // sendBye(request,device,key);
}); // });
} }
private Flow.Subscriber<SIPRequest> ffmpegTask(SIPRequest request,ConcurrentHashMap<String, Executor> tasks, String callId, String key, MockingDevice device){ private Flow.Subscriber<SIPRequest> ffmpegTask(SIPRequest request,ConcurrentHashMap<String, Executor> tasks, String callId, String key, MockingDevice device){