sys启动后只连接订阅客户端

zgzt-sys-java/jeecg-module-conn/src/main/java/org/jeecg/modules/push/utils/MqttClientUtil.java

@@ -170,7 +170,7 @@ public class MqttClientUtil implements ApplicationRunner {
 
     @Override
     public void run(ApplicationArguments args) {
-        LambdaQueryWrapper<ConfigMqtt> eq = new LambdaQueryWrapper<ConfigMqtt>().ne(ConfigMqtt::getPushOrSub, "1");
+        LambdaQueryWrapper<ConfigMqtt> eq = new LambdaQueryWrapper<ConfigMqtt>().eq(ConfigMqtt::getPushOrSub, "1");
         List<ConfigMqtt> configMqtts = configMqttMapper.selectList(eq);
         for (ConfigMqtt configMqtt : configMqtts) {
             try {