| | |
|---|
| | | String channelId = ssrcTransactionForAll.get(0).getChannelId();
|
|---|
| | | DeviceChannel deviceChannel = storager.queryChannel(deviceId, channelId);
|
|---|
| | | if (deviceChannel != null) {
|
|---|
| | | result.setEnable_audio(deviceChannel.isHasAudio());
|
|---|
| | | result.setEnable_audio(deviceChannel.getHasAudio());
|
|---|
| | | }
|
|---|
| | | // 如果是录像下载就设置视频间隔十秒
|
|---|
| | | if (ssrcTransactionForAll.get(0).getType() == InviteSessionType.DOWNLOAD) {
|
|---|
| | |
|---|
| | | }
|
|---|
| | | if (sendRtpItem.getApp().equals(param.getApp())) {
|
|---|
| | | // 在hook收到这个消息，说明发流一定是本级完成的。
|
|---|
| | | redisCatchStorage.deleteSendRTPServer(sendRtpItem);
|
|---|
| | | ssrcFactory.releaseSsrc(sendRtpItem.getMediaServerId(), sendRtpItem.getSsrc());
|
|---|
| | | ParentPlatform platform = storager.queryParentPlatByServerGBId(sendRtpItem.getPlatformId());
|
|---|
| | | Device device = deviceService.getDevice(sendRtpItem.getPlatformId());
|
|---|
| | | try {
|
|---|
| | | if (platform != null) {
|
|---|
| | | commanderFroPlatform.streamByeCmd(platform, sendRtpItem);
|
|---|
| | | redisCatchStorage.deleteSendRTPServer(sendRtpItem);
|
|---|
| | | redisCatchStorage.sendPlatformStopPlayMsg(sendRtpItem, platform);
|
|---|
| | | } else if (device != null) {
|
|---|
| | | cmder.streamByeCmd(device, sendRtpItem.getChannelId(), param.getStream(), sendRtpItem.getCallId());
|
|---|
| | |
|---|
| | | }
|
|---|
| | | }else {
|
|---|
| | | // 通知其他wvp停止发流
|
|---|
| | | redisRpcService.rtpSendStopped(sendRtpItem);
|
|---|
| | | redisRpcService.rtpSendStopped(sendRtpItem.getRedisKey());
|
|---|
| | | }
|
|---|
| | | } catch (SipException | InvalidArgumentException | ParseException |
|
|---|
| | | SsrcTransactionNotFoundException e) {
|
|---|
