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();