|
|
@@ -132,8 +132,8 @@ public class DefaultWebSocketMsgHandler implements IWsMsgHandler {
|
|
|
.collect(Collectors.toList());
|
|
|
//传入格式错误,不支持该订阅id
|
|
|
if(CollUtil.isEmpty(collect)){
|
|
|
- channelContext.setClosed(true);
|
|
|
- Tio.remove(channelContext, "接受数据不符合业务规范");
|
|
|
+// channelContext.setClosed(true);
|
|
|
+// Tio.remove(channelContext, "接受数据不符合业务规范");
|
|
|
return;
|
|
|
}
|
|
|
collect.forEach(handler->handler.onMessage(messagingRequest,channelContext));
|