From 55c682d4cd05b90a28c48008f1856c6ffdc5ea3e Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Fri, 24 Mar 2023 17:22:30 +0800 Subject: [PATCH] 后台修改 --- src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java b/src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java index 809998e..f7022fe 100644 --- a/src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java +++ b/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(); // 将递归重试连接和订阅改为有限次数的重试,避免出现无限递归的情况 -- Gitblit v1.9.1