|
|
@@ -731,6 +731,7 @@ public class InviteRequestProcessor extends SIPRequestProcessorParent implements
|
|
|
dynamicTask.startDelay(callIdHeader.getCallId(), () -> {
|
|
|
logger.info("[ app={}, stream={} ] 等待设备开始推流超时", gbStream.getApp(), gbStream.getStream());
|
|
|
try {
|
|
|
+ redisPushStreamResponseListener.removeEvent(gbStream.getApp(), gbStream.getStream());
|
|
|
mediaListManager.removedChannelOnlineEventLister(gbStream.getApp(), gbStream.getStream());
|
|
|
responseAck(request, Response.REQUEST_TIMEOUT); // 超时
|
|
|
} catch (SipException e) {
|
|
|
@@ -748,6 +749,7 @@ public class InviteRequestProcessor extends SIPRequestProcessorParent implements
|
|
|
// 添加在本机上线的通知
|
|
|
mediaListManager.addChannelOnlineEventLister(gbStream.getApp(), gbStream.getStream(), (app, stream, serverId) -> {
|
|
|
dynamicTask.stop(callIdHeader.getCallId());
|
|
|
+ redisPushStreamResponseListener.removeEvent(gbStream.getApp(), gbStream.getStream());
|
|
|
if (serverId.equals(userSetting.getServerId())) {
|
|
|
SendRtpItem sendRtpItem = zlmServerFactory.createSendRtpItem(mediaServerItem, addressStr, finalPort, ssrc, requesterId,
|
|
|
app, stream, channelId, mediaTransmissionTCP, platform.isRtcp());
|