From 5fc84fec1dd242571328bbd9321a47a7adcfcb1f Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期五, 29 十二月 2023 12:19:04 +0800
Subject: [PATCH] 提交邦海智能自有协议-1
---
src/main/java/com/fzzy/mqtt/MqttGatewayService.java | 31 +++++++++++++++++++++++++++++++
1 files changed, 31 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/fzzy/mqtt/MqttGatewayService.java b/src/main/java/com/fzzy/mqtt/MqttGatewayService.java
new file mode 100644
index 0000000..f86ede5
--- /dev/null
+++ b/src/main/java/com/fzzy/mqtt/MqttGatewayService.java
@@ -0,0 +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;
+
+
+@MessagingGateway(defaultRequestChannel = "mqttOutboundChannel")
+public interface MqttGatewayService {
+
+ /**
+ * 鍙戦�佷俊鎭埌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