Commit f3acf33fbf8b9db0ca6231f4648f0761340cbb1e
1 parent
6120e6bd
添加日志
Showing
1 changed file
with
3 additions
and
2 deletions
src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisGpsMsgListener.java
| @@ -50,11 +50,12 @@ public class RedisGpsMsgListener implements MessageListener { | @@ -50,11 +50,12 @@ public class RedisGpsMsgListener implements MessageListener { | ||
| 50 | Message msg = taskQueue.poll(); | 50 | Message msg = taskQueue.poll(); |
| 51 | try { | 51 | try { |
| 52 | GPSMsgInfo gpsMsgInfo = JSON.parseObject(msg.getBody(), GPSMsgInfo.class); | 52 | GPSMsgInfo gpsMsgInfo = JSON.parseObject(msg.getBody(), GPSMsgInfo.class); |
| 53 | + logger.info("[REDIS的位置变化通知], {}", JSON.toJSONString(gpsMsgInfo)); | ||
| 53 | // 只是放入redis缓存起来 | 54 | // 只是放入redis缓存起来 |
| 54 | redisCatchStorage.updateGpsMsgInfo(gpsMsgInfo); | 55 | redisCatchStorage.updateGpsMsgInfo(gpsMsgInfo); |
| 55 | }catch (Exception e) { | 56 | }catch (Exception e) { |
| 56 | - logger.warn("[REDIS的ALARM通知] 发现未处理的异常, \r\n{}", JSON.toJSONString(message)); | ||
| 57 | - logger.error("[REDIS的ALARM通知] 异常内容： ", e); | 57 | + logger.warn("[REDIS的位置变化通知] 发现未处理的异常, \r\n{}", JSON.toJSONString(message)); |
| 58 | + logger.error("[REDIS的位置变化通知] 异常内容： ", e); | ||
| 58 | } | 59 | } |
| 59 | } | 60 | } |
| 60 | }); | 61 | }); |