| | |
|---|
| | | String channelId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(ToHeader.NAME)).getAddress().getURI()).getUser(); |
|---|
| | | SendRtpItem sendRtpItem = redisCatchStorage.querySendRTPServer(platformGbId, null, null, callIdHeader.getCallId()); |
|---|
| | | logger.info("收到bye, [{}/{}]", platformGbId, channelId); |
|---|
| | | if (sendRtpItem != null){ |
|---|
| | | if (sendRtpItem != null ){ |
|---|
| | | String streamId = sendRtpItem.getStreamId(); |
|---|
| | | Map<String, Object> param = new HashMap<>(); |
|---|
| | | param.put("vhost","__defaultVhost__"); |
|---|
| | |
|---|
| | | playService.stopAudioBroadcast(sendRtpItem.getDeviceId(), sendRtpItem.getChannelId()); |
|---|
| | | } |
|---|
| | | if (sendRtpItem.getPlayType().equals(InviteStreamType.PUSH)) { |
|---|
| | | MessageForPushChannel messageForPushChannel = new MessageForPushChannel(); |
|---|
| | | messageForPushChannel.setType(0); |
|---|
| | | messageForPushChannel.setGbId(sendRtpItem.getChannelId()); |
|---|
| | | messageForPushChannel.setApp(sendRtpItem.getApp()); |
|---|
| | | messageForPushChannel.setStream(sendRtpItem.getStreamId()); |
|---|
| | | messageForPushChannel.setMediaServerId(sendRtpItem.getMediaServerId()); |
|---|
| | | messageForPushChannel.setPlatFormId(sendRtpItem.getPlatformId()); |
|---|
| | | MessageForPushChannel messageForPushChannel = MessageForPushChannel.getInstance(0, |
|---|
| | | sendRtpItem.getApp(), sendRtpItem.getStreamId(), sendRtpItem.getChannelId(), |
|---|
| | | sendRtpItem.getPlatformId(), null, null, sendRtpItem.getMediaServerId()); |
|---|
| | | redisCatchStorage.sendStreamPushRequestedMsg(messageForPushChannel); |
|---|
| | | } |
|---|
| | | } |
|---|
