后台修改

xiaoyong931011

2023-03-24 55c682d4cd05b90a28c48008f1856c6ffdc5ea3e

后台修改

 src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java

@@ -199,7 +199,7 @@
                // 等待订阅事件流的线程结束，然后关闭连接和释放资源
                executor.schedule(ws::close, 1, TimeUnit.SECONDS);
                executor.awaitTermination(10, TimeUnit.SECONDS);
                subscribe.dispose();
//                subscribe.dispose();
            } catch (InterruptedException e) {
                e.printStackTrace();
                // 将递归重试连接和订阅改为有限次数的重试，避免出现无限递归的情况