修改公交公司的事件订阅功能

puzhibing

6 天以前 390329f37fee525ab24beea271271c133543a594

修改公交公司的事件订阅功能

 ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/controller/UPWarnMsgAdptInfoController.java

@@ -91,15 +91,5 @@
        return R.ok();
    }
    
	
    /**
     * 海康威视报警信息推送
     * @return
     */
    @ResponseBody
    @PostMapping("/alarmNotice")
    public void alarmNotice(@RequestBody SubscriptionEvent event) {
        log.error("收到危海康的事件回调");
        log.error(JSON.toJSONString(event));
    }

}

 ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/util/mqtt/MqttInit.java

@@ -14,6 +14,7 @@
@Slf4j
@Component
public class MqttInit {

    @Autowired
    private MqttPahoMessageDrivenChannelAdapter messageDrivenChannelAdapter;
    
@@ -21,6 +22,8 @@
    public void init() {
        subscribeAllTopics();
    }


    public void subscribeAllTopics() {
        messageDrivenChannelAdapter.addTopic("artemis/event_msa_alarm/5201154049/admin");
    }

 ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/util/mqtt/MqttReceiverMessageHandler.java

@@ -18,7 +18,7 @@
    @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());
        // 消息保存到内存队列里面，定时批量入库，也可以在这里直接入库