支持从redis消息更新推流设备状态

648540858
1 parent 81f69eb6
Showing 1 changed file with 8 additions and 0 deletions
src/main/java/com/genersoft/iot/vmp/storager/impl/RedisCatchStorageImpl.java
@@ -707,4 +707,12 @@ public class RedisCatchStorageImpl implements IRedisCatchStorage {
     }
+    @Override
+    public void sendStreamPushRequestedMsgForStatus() {
+        String key = VideoManagerConstants.VM_MSG_GET_ALL_ONLINE_REQUESTED;
+        logger.info("[redis 通知]获取所有推流设备的状态");
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put(key, key);
+        redis.convertAndSend(key, jsonObject);
+    }
 }