diff --git a/detection/src/main/java/com/njcn/gather/detection/handler/SocketSourceResponseService.java b/detection/src/main/java/com/njcn/gather/detection/handler/SocketSourceResponseService.java index 973fa775..be88a1aa 100644 --- a/detection/src/main/java/com/njcn/gather/detection/handler/SocketSourceResponseService.java +++ b/detection/src/main/java/com/njcn/gather/detection/handler/SocketSourceResponseService.java @@ -209,6 +209,10 @@ public class SocketSourceResponseService { case UNPROCESSED_BUSINESS: WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(socketDataMsg)); break; + case UNKNOWN_ERROR: + CnSocketUtil.quitSendSource(param); + WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(socketDataMsg)); + break; default: CnSocketUtil.quitSendSource(param); socketMsg.setRequestId(socketDataMsg.getRequestId()); @@ -327,6 +331,10 @@ public class SocketSourceResponseService { case MESSAGE_PARSING_ERROR: CnSocketUtil.quitSendSource(param); break; + case UNKNOWN_ERROR: + CnSocketUtil.quitSendSource(param); + WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(socketDataMsg)); + break; default: CnSocketUtil.quitSendSource(param); socketMsg.setRequestId(socketDataMsg.getRequestId()); @@ -407,6 +415,10 @@ public class SocketSourceResponseService { case UNPROCESSED_BUSINESS: WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(socketDataMsg)); break; + case UNKNOWN_ERROR: + CnSocketUtil.quitSendSource(param); + WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(socketDataMsg)); + break; default: CnSocketUtil.quitSendSource(param); socketMsg.setRequestId(socketDataMsg.getRequestId());