| | |
| | | @Override |
| | | public void handleMessage(Message<?> message) throws MessagingException { |
| | | MessageHeaders headers = message.getHeaders(); |
| | | log.info("线程名称:{},收到消息,主题:{},消息:{}", Thread.currentThread().getName(), headers.get("mqtt_receivedTopic").toString(), message.getPayload()); |
| | | log.error("线程名称:{},收到消息,主题:{},消息:{}", Thread.currentThread().getName(), headers.get("mqtt_receivedTopic").toString(), message.getPayload()); |
| | | // log.info("收到消息主题:{}", headers.get("mqtt_receivedTopic").toString()); |
| | | // log.info("收到消息:{}", message.getPayload()); |
| | | String s = message.getPayload().toString(); |
| | |
| | | switch (ability){ |
| | | case "event_msa_alarm": |
| | | warnMsgService.saveWarnMsgService(jsonObject); |
| | | break; |
| | | case "event_msa_pic": |
| | | warnMsgService.saveWarnMsgPicService(jsonObject); |
| | | break; |
| | | } |
| | | } |