xiaoyong931011
2023-03-24 a4e2632242680c2af350af9ef4498413aa99dd92
src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java
@@ -194,7 +194,7 @@
            try{
                // 等待订阅事件流的线程结束,然后关闭连接和释放资源
                executor.schedule(ws::close, 1, TimeUnit.SECONDS);
                executor.awaitTermination(2, TimeUnit.SECONDS);
                executor.awaitTermination(10, TimeUnit.SECONDS);
                subscribe.dispose();
            } catch (InterruptedException e) {
                e.printStackTrace();