| | |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public void streamByeCmd(Device device, String channelId, String stream, String callId, SipSubscribe.Event okEvent) throws InvalidArgumentException, SipException, ParseException, SsrcTransactionNotFoundException { |
|---|
| | | if (device == null) { |
|---|
| | | logger.warn("[发送BYE] device为null"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | List<SsrcTransaction> ssrcTransactionList = streamSession.getSsrcTransactionForAll(device.getDeviceId(), channelId, callId, stream); |
|---|
| | | if (ssrcTransactionList == null || ssrcTransactionList.isEmpty()) { |
|---|
| | | logger.info("[发送BYE] 未找到事务信息,设备： device: {}, channel: {}", device.getDeviceId(), channelId); |
|---|
| | | throw new SsrcTransactionNotFoundException(device.getDeviceId(), channelId, callId, stream); |
|---|
| | | } |
|---|
| | | |
|---|
| | | for (SsrcTransaction ssrcTransaction : ssrcTransactionList) { |
|---|
| | | logger.info("[发送BYE] 设备： device: {}, channel: {}, callId: {}", device.getDeviceId(), channelId, ssrcTransaction.getCallId()); |
|---|
| | | mediaServerService.releaseSsrc(ssrcTransaction.getMediaServerId(), ssrcTransaction.getSsrc()); |
|---|
| | | |
|---|
| | | mediaServerService.closeRTPServer(ssrcTransaction.getMediaServerId(), ssrcTransaction.getStream()); |
|---|
| | | streamSession.removeByCallId(ssrcTransaction.getDeviceId(), ssrcTransaction.getChannelId(), ssrcTransaction.getCallId()); |
|---|
| | | |
|---|
| | | Request byteRequest = headerProvider.createByteRequest(device, channelId, ssrcTransaction.getSipTransactionInfo()); |
|---|
| | | sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), byteRequest, null, okEvent); |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
