This commit is contained in:
caozehui
2025-05-26 16:24:21 +08:00
parent 57b08a99c6
commit bf661b5c1c

View File

@@ -55,9 +55,9 @@ public class WebServiceManager {
channel.writeAndFlush(wd);
}else {
log.error("{}-websocket推送消息失败;当前用户-{}-客户端已经断开连接", LocalDateTime.now(),userId);
PreDetectionParam param = preDetectionParamMap.get("preDetectionParam");
CnSocketUtil.quitSend(param);
CnSocketUtil.quitSendSource(param);
// PreDetectionParam param = preDetectionParamMap.get("preDetectionParam");
// CnSocketUtil.quitSend(param);
// CnSocketUtil.quitSendSource(param);
}
}