jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/controller/DryRealTimeDataController.java
@@ -94,7 +94,7 @@ @PostMapping("/sendRealTimeDataJson") public Result<?> realTimeDataJson(@RequestBody RealTimeDataVo realTimeDataVo) { try { if ("user".equals(mqttConfig.getRole())){ if (mqttConfig.isEnable() && "user".equals(mqttConfig.getRole())){ MqttMessage mqttMessage = new MqttMessage(); mqttMessage.setQos(0); mqttMessage.setPayload(JSONObject.toJSONString(realTimeDataVo).getBytes()); jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttConfig.java
@@ -36,6 +36,8 @@ private String mqttClientId; @Value(value = "${jeecg.mqtt.role}") private String role; @Value(value = "${jeecg.mqtt.enable}") private boolean enable; @Autowired private MqttSampleCallback mqttSampleCallback; @@ -59,6 +61,7 @@ * mqtt连接配置 */ private void conn() { if (!isEnable()) return; MemoryPersistence persistence = new MemoryPersistence(); MqttConnectOptions mqttConnOpt = new MqttConnectOptions(); mqttConnOpt.setUserName(mqttName); @@ -132,6 +135,7 @@ //重连 private void reconn() { if (!isEnable()) return; Timer timer = new Timer(); TimerTask task = new TimerTask() {
