| | |
| | | @Override |
| | | public void sendMobilePositionMsg(JSONObject jsonObject) { |
| | | String key = VideoManagerConstants.VM_MSG_SUBSCRIBE_MOBILE_POSITION; |
| | | logger.info("[redis 移动位置订阅通知] {}: {}", key, jsonObject.toString()); |
| | | logger.info("[redis发送通知]移动位置 {}: {}", key, jsonObject.toString()); |
| | | redis.convertAndSend(key, jsonObject); |
| | | } |
| | | |
| | | @Override |
| | | public void sendStreamPushRequestedMsg(MessageForPushChannel msg) { |
| | | String key = VideoManagerConstants.VM_MSG_STREAM_PUSH_REQUESTED; |
| | | logger.info("[redis 推流被请求通知] {}: {}/{}", key, msg.getApp(), msg.getStream()); |
| | | logger.info("[redis发送通知]推流被请求 {}: {}/{}", key, msg.getApp(), msg.getStream()); |
| | | redis.convertAndSend(key, (JSONObject)JSON.toJSON(msg)); |
| | | } |
| | | |
| | | @Override |
| | | public void sendAlarmMsg(AlarmChannelMessage msg) { |
| | | String key = VideoManagerConstants.VM_MSG_SUBSCRIBE_ALARM; |
| | | logger.info("[redis 报警通知] {}: {}", key, JSON.toJSON(msg)); |
| | | logger.info("[redis发送通知] 报警{}: {}", key, JSON.toJSON(msg)); |
| | | redis.convertAndSend(key, (JSONObject)JSON.toJSON(msg)); |
| | | } |
| | | |
| | |
| | | @Override |
| | | public void sendStreamPushRequestedMsgForStatus() { |
| | | String key = VideoManagerConstants.VM_MSG_GET_ALL_ONLINE_REQUESTED; |
| | | logger.info("[redis 通知]获取所有推流设备的状态"); |
| | | logger.info("[redis通知]获取所有推流设备的状态"); |
| | | JSONObject jsonObject = new JSONObject(); |
| | | jsonObject.put(key, key); |
| | | redis.convertAndSend(key, jsonObject); |