奉贤数据单独使用 job处理

This commit is contained in:
2025-06-29 13:13:23 +08:00
parent d1aa8dbd2c
commit bb0f972f55

View File

@ -89,7 +89,7 @@ public class MqttMessageController implements MqttPublisher, MqttSubscriber {
System.out.println("[DEVICE] data: " + payload); System.out.println("[DEVICE] data: " + payload);
try { try {
// 业务处理逻辑 // 业务处理逻辑
handleFxData(payload); // handleFxData(payload);
EmsMqttMessage mqttMessage = new EmsMqttMessage(); EmsMqttMessage mqttMessage = new EmsMqttMessage();
mqttMessage.setMqttTopic(topic); mqttMessage.setMqttTopic(topic);