fusen/fusenapi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
laodaming 2023-08-25 14:52:42 +08:00
parent 826ba92b8e
commit b5b3042226
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/websocket/internal/logic/commonnotifylogic.go
View File

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