From d41d6b34af2485198ed01e1888db1571e4da1a6a Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: 星期二, 23 四月 2024 20:59:20 +0800 Subject: [PATCH] Merge branch 'refs/heads/2.7.0' --- src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java | 13 ++++++++++++- 1 files changed, 12 insertions(+), 1 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 1233623..21911b9 100755 --- a/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java +++ b/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java @@ -45,6 +45,8 @@ void updateSendRTPSever(SendRtpItem sendRtpItem); + List<SendRtpItem> querySendRTPServer(String platformGbId, String channelId, String streamId); + /** * 鏌ヨRTP鎺ㄩ�佷俊鎭紦瀛� * @param platformGbId @@ -197,6 +199,8 @@ void addDiskInfo(List<Map<String, Object>> diskInfo); + void deleteSendRTPServer(SendRtpItem sendRtpItem); + List<SendRtpItem> queryAllSendRTPServer(); List<Device> getAllDevices(); @@ -209,7 +213,7 @@ void sendPlatformStartPlayMsg(MessageForPushChannel messageForPushChannel); - void sendPlatformStopPlayMsg(MessageForPushChannel messageForPushChannel); + void sendPlatformStopPlayMsg(SendRtpItem sendRtpItem, ParentPlatform platform); void addPushListItem(String app, String stream, MediaArrivalEvent param); @@ -219,4 +223,11 @@ void sendPushStreamClose(MessageForPushChannel messageForPushChannel); + void addWaiteSendRtpItem(SendRtpItem sendRtpItem, int platformPlayTimeout); + + SendRtpItem getWaiteSendRtpItem(String app, String stream); + + void sendStartSendRtp(SendRtpItem sendRtpItem); + + void sendPushStreamOnline(SendRtpItem sendRtpItem); } -- Gitblit v1.8.0