| | |
| | | @Value("${media.record-day:7}") |
| | | private Integer recordDay; |
| | | |
| | | @Value("${media.record-path}") |
| | | @Value("${media.record-path:}") |
| | | private String recordPath; |
| | | |
| | | public String getId() { |
| | |
| | | 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) { |
| | |
| | | // 添加在本机上线的通知 |
| | | 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()); |
| | |
| | | param.put("rtp_proxy.port_range", mediaServerItem.getRtpPortRange().replace(",", "-")); |
| | | } |
| | | |
| | | if (mediaServerItem.getRecordPath() != null) { |
| | | if (!ObjectUtils.isEmpty(mediaServerItem.getRecordPath())) { |
| | | File recordPathFile = new File(mediaServerItem.getRecordPath()); |
| | | param.put("protocol.mp4_save_path", recordPathFile.getParentFile().getPath()); |
| | | param.put("protocol.downloadRoot", recordPathFile.getParentFile().getPath()); |