水肥、气象、墒情最新、历史数据查询测试并修改bug

liurunyu

2025-06-27 63a3920ea3d17f8a677d4edc9ffaab279367cb70

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/mqtt/Test.java

@@ -34,7 +34,7 @@
    public static void main(String[] args) {
        try{
            // 初始化连接池
            pool = new MqttClientPool("tcp://" + mqSvIp + ":" + mqSvPort, mqSvUserName, mqSvUserPassword, maxConnections);
            pool = new MqttClientPool("tcp://" + mqSvIp + ":" + mqSvPort, mqSvUserName, mqSvUserPassword, maxConnections, true);
            MqttClient clientSub = pool.popClient() ;
            testSubscribe(clientSub, topic1);
            testSubscribe(clientSub, topic2);