From b37a77f23f995758178b6af38b89a860107d218d Mon Sep 17 00:00:00 2001 From: panlinlin <648540858@qq.com> Date: 星期四, 25 三月 2021 16:45:29 +0800 Subject: [PATCH] 解决循环依赖导致的打包失败 --- src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java | 47 +++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 47 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java b/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java index 8bc78b9..9061184 100644 --- a/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java +++ b/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java @@ -2,6 +2,9 @@ import com.genersoft.iot.vmp.common.StreamInfo; import com.genersoft.iot.vmp.conf.MediaServerConfig; +import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform; +import com.genersoft.iot.vmp.gb28181.bean.ParentPlatformCatch; +import com.genersoft.iot.vmp.gb28181.bean.SendRtpItem; import java.util.Map; @@ -55,4 +58,48 @@ boolean stopPlayback(StreamInfo streamInfo); StreamInfo queryPlaybackByDevice(String deviceId, String code); + + void updatePlatformCatchInfo(ParentPlatformCatch parentPlatformCatch); + + ParentPlatformCatch queryPlatformCatchInfo(String platformGbId); + + void delPlatformCatchInfo(String platformGbId); + + void updatePlatformKeepalive(ParentPlatform parentPlatform); + + void delPlatformKeepalive(String platformGbId); + + void updatePlatformRegister(ParentPlatform parentPlatform); + + void delPlatformRegister(String platformGbId); + + void updatePlatformRegisterInfo(String callId, String platformGbId); + + String queryPlatformRegisterInfo(String callId); + + void delPlatformRegisterInfo(String callId); + + void updateSendRTPSever(SendRtpItem sendRtpItem); + + /** + * 鏌ヨRTP鎺ㄩ�佷俊鎭紦瀛� + * @param platformGbId + * @param channelId + * @return sendRtpItem + */ + SendRtpItem querySendRTPServer(String platformGbId, String channelId); + + /** + * 鍒犻櫎RTP鎺ㄩ�佷俊鎭紦瀛� + * @param platformGbId + * @param channelId + */ + void deleteSendRTPServer(String platformGbId, String channelId); + + /** + * 鏌ヨ鏌愪釜閫氶亾鏄惁瀛樺湪涓婄骇鐐规挱锛圧TP鎺ㄩ�侊級 + * @param channelId + */ + boolean isChannelSendingRTP(String channelId); + } -- Gitblit v1.8.0