Merge remote-tracking branch 'origin/master'
| | |
| | | public void messageArrived(String topic, MqttMessage message) { |
| | | try { |
| | | // subscribe后得到的消息会执行到这里面 |
| | | log.debug("接收消息 【主题】:" + topic + " 【内容】:" + new String(message.getPayload())); |
| | | log.debug("接收消息 【主题】:" + topic + " 【内容】:" + new String(message.getPayload(), StandardCharsets.UTF_8)); |
| | | //进行业务处理(接收报警数据) |
| | | GlobalAlarmServiceImpl globalAlarmService = SpringUtils.getBean(GlobalAlarmServiceImpl.class); |
| | | globalAlarmService.receiveAlarm(topic, new String(message.getPayload(), StandardCharsets.UTF_8)); |