加入状态反馈，还没具体测试

yangys

2024-09-27 26f8e5990686bdba2119024a260d986266506757

 collect/src/main/java/com/qianwen/mdc/collect/mqtt/MqttMessageSender.java

@@ -1,6 +1,7 @@
package com.qianwen.mdc.collect.mqtt;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Service;
@@ -12,7 +13,7 @@

    public void sendMessage(String topic, String payload) {
        mqttOutboundChannel.send(MessageBuilder.withPayload(payload)
                .setHeader("mqtt_topic", topic)
                .setHeader(MqttHeaders.TOPIC, topic)
                .build());
        
    }