增加mqtt启用开关

baoshiwei

2024-12-11 7d22ff04f867071ed77809fb08f103446738eeec

 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() {