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-09-21 17:08:04 +08:00
parent f7c0d90ab3
commit bcbcf0a4b2
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

@ -28,7 +28,7 @@ func NewCommonNotifyLogic(ctx context.Context, svcCtx *svc.ServiceContext) *Comm
} }
// 定义公共回调未找到websocket连接时暂存数据缓冲队列 // 定义公共回调未找到websocket连接时暂存数据缓冲队列
var commonConnectionNotFoundDataCacheChan = make(chan commonConnectionNotFoundDataCacheChanItem, 2000) var commonConnectionNotFoundDataCacheChan = make(chan commonConnectionNotFoundDataCacheChanItem, 100)
type commonConnectionNotFoundDataCacheChanItem struct { type commonConnectionNotFoundDataCacheChanItem struct {
retryTimes int //重回队列次数 retryTimes int //重回队列次数