From a69402c8b67d8ce4b698d0c394d15ff43b5d99d0 Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期四, 14 十二月 2023 23:17:41 +0800
Subject: [PATCH] 提交正来电子协议解析-3
---
src/main/java/com/fzzy/mqtt/MqttGatewayService.java | 28 +++++++++++++++++++++-------
1 files changed, 21 insertions(+), 7 deletions(-)
diff --git a/src/main/java/com/fzzy/mqtt/MqttGatewayService.java b/src/main/java/com/fzzy/mqtt/MqttGatewayService.java
index caed4e8..f86ede5 100644
--- a/src/main/java/com/fzzy/mqtt/MqttGatewayService.java
+++ b/src/main/java/com/fzzy/mqtt/MqttGatewayService.java
@@ -1,17 +1,31 @@
package com.fzzy.mqtt;
-
import org.springframework.integration.annotation.MessagingGateway;
import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.handler.annotation.Header;
-import org.springframework.stereotype.Service;
-/**
- * 鎺ㄩ�佹帴鍙�
- */
-@Service
+
@MessagingGateway(defaultRequestChannel = "mqttOutboundChannel")
public interface MqttGatewayService {
- void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic01, String sendData);
+ /**
+ * 鍙戦�佷俊鎭埌MQTT鏈嶅姟鍣�
+ *
+ * @param topic 涓婚
+ * @param message 娑堟伅涓讳綋
+ */
+ void publishMqttWithTopic(String message, @Header(MqttHeaders.TOPIC) String topic);
+
+ /**
+ * 鍙戦�佷俊鎭埌MQTT鏈嶅姟鍣�
+ *
+ * @param topic 涓婚
+ * @param qos 瀵规秷鎭鐞嗙殑鍑犵鏈哄埗銆�<br> 0 琛ㄧず鐨勬槸璁㈤槄鑰呮病鏀跺埌娑堟伅涓嶄細鍐嶆鍙戦�侊紝娑堟伅浼氫涪澶便��<br>
+ * 1 琛ㄧず鐨勬槸浼氬皾璇曢噸璇曪紝涓�鐩村埌鎺ユ敹鍒版秷鎭紝浣嗚繖绉嶆儏鍐靛彲鑳藉鑷磋闃呰�呮敹鍒板娆￠噸澶嶆秷鎭��<br>
+ * 2 澶氫簡涓�娆″幓閲嶇殑鍔ㄤ綔锛岀‘淇濊闃呰�呮敹鍒扮殑娑堟伅鏈変竴娆°��
+ * @param message 娑堟伅涓讳綋
+ */
+ void publishMqttWithTopic(String message, @Header(MqttHeaders.TOPIC) String topic, @Header(MqttHeaders.QOS) int qos);
+
+
}
--
Gitblit v1.9.3