From d4212be4f036c5972e192a93e9a7f3a2e3bb2535 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期六, 28 九月 2024 15:26:39 +0800
Subject: [PATCH] 加入logback配置
---
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