This commit is contained in:
laodaming 2023-08-25 14:59:36 +08:00
parent b5b3042226
commit a635a2f546

View File

@ -100,7 +100,7 @@ func (l *CommonNotifyLogic) CommonNotify(req *types.CommonNotifyReq, userinfo *a
return resp.SetStatusWithMessage(basic.CodeRequestParamsErr, "websocket connect id is empty")
}
//触发消费公共未处理的消息(该方法是单例)
l.consumeCommonCacheData()
go l.consumeCommonCacheData()
//查询websocket连接
value, ok := mapConnPool.Load(req.Wid)
if !ok {