From 16f093ea132a823e255f446c225ce6b63fdb9eeb Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期四, 24 十月 2024 10:15:46 +0800
Subject: [PATCH] appId映射修改
---
collect/src/main/java/com/qianwen/mdc/collect/mqtt/MqttMessageSender.java | 3 ++-
1 files changed, 2 insertions(+), 1 deletions(-)
diff --git a/collect/src/main/java/com/qianwen/mdc/collect/mqtt/MqttMessageSender.java b/collect/src/main/java/com/qianwen/mdc/collect/mqtt/MqttMessageSender.java
index f849e0a..fe1dd0b 100644
--- a/collect/src/main/java/com/qianwen/mdc/collect/mqtt/MqttMessageSender.java
+++ b/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());
}
--
Gitblit v1.9.3