|
|
@@ -0,0 +1,14 @@
|
|
|
+import com.fs.framework.config.MqttGateway;
|
|
|
+import org.junit.jupiter.api.Test;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+
|
|
|
+public class MQTTTest extends BaseSpringBootTest{
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private MqttGateway mqttGateway;
|
|
|
+
|
|
|
+ @Test
|
|
|
+ void mqttTest(){
|
|
|
+ mqttGateway.sendToTopic("test/topic","test");
|
|
|
+ }
|
|
|
+}
|