| | |
|---|
| | | MessageForPushChannel pushChannel = JSON.parseObject(message.getBody(), MessageForPushChannel.class); |
|---|
| | | StreamPushItem push = streamPushService.getPush(pushChannel.getApp(), pushChannel.getStream()); |
|---|
| | | if (push != null) { |
|---|
| | | List<SendRtpItem> sendRtpItems = redisCatchStorage.querySendRTPServerByChnnelId( |
|---|
| | | List<SendRtpItem> sendRtpItems = redisCatchStorage.querySendRTPServerByChannelId( |
|---|
| | | push.getGbId()); |
|---|
| | | if (!sendRtpItems.isEmpty()) { |
|---|
| | | for (SendRtpItem sendRtpItem : sendRtpItems) { |
|---|
| | | ParentPlatform parentPlatform = storager.queryParentPlatByServerGBId(sendRtpItem.getPlatformId()); |
|---|
| | | if (parentPlatform != null) { |
|---|
| | | redisCatchStorage.deleteSendRTPServer(sendRtpItem.getPlatformId(), sendRtpItem.getChannelId(), sendRtpItem.getCallId(), sendRtpItem.getStreamId()); |
|---|
| | | redisCatchStorage.deleteSendRTPServer(sendRtpItem.getPlatformId(), sendRtpItem.getChannelId(), sendRtpItem.getCallId(), sendRtpItem.getStream()); |
|---|
| | | try { |
|---|
| | | commanderFroPlatform.streamByeCmd(parentPlatform, sendRtpItem); |
|---|
| | | } catch (SipException | InvalidArgumentException | ParseException e) { |
|---|
