| | |
| | | + channelId + "_" |
| | | + streamId + "_" |
| | | + callId; |
| | | logger.info("[删除 redis的SendRTP]: {}", key); |
| | | List<Object> scan = RedisUtil.scan(redisTemplate, key); |
| | | if (scan.size() > 0) { |
| | | for (Object keyStr : scan) { |
| | | logger.info("[删除 redis的SendRTP]: {}", keyStr.toString()); |
| | | redisTemplate.delete(keyStr); |
| | | } |
| | | } |
| | |
| | | @Override |
| | | public void sendMobilePositionMsg(JSONObject jsonObject) { |
| | | String key = VideoManagerConstants.VM_MSG_SUBSCRIBE_MOBILE_POSITION; |
| | | logger.info("[redis发送通知] 发送 移动位置 {}: {}", key, jsonObject.toString()); |
| | | logger.debug("[redis发送通知] 发送 移动位置 {}: {}", key, jsonObject.toString()); |
| | | redisTemplate.convertAndSend(key, jsonObject); |
| | | } |
| | | |