phyer/siaga
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

只收到一条消息问题的修复

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2024-12-17 07:17:33 +08:00
parent 2a84f2eda9
commit 6fdf9b433e
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
modules/extent.go
View File

@ -103,7 +103,6 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi
break break
} }
cr.CandlesProcessChan <- &cd cr.CandlesProcessChan <- &cd
continue
} }
// 接收到的maX扔到 maX 二次加工流水线 // 接收到的maX扔到 maX 二次加工流水线
@ -119,7 +118,6 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi
dt = append(dt, mx.AvgVal) dt = append(dt, mx.AvgVal)
mx.Data = dt mx.Data = dt
cr.MaXProcessChan <- &mx cr.MaXProcessChan <- &mx
continue
} }
// 接收到的tinckerInfo扔到 tickerInfo 二次加工流水线 // 接收到的tinckerInfo扔到 tickerInfo 二次加工流水线
@ -132,7 +130,6 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi
logrus.Warning("tickerInfo payload unmarshal err: ", err, msg.Payload) logrus.Warning("tickerInfo payload unmarshal err: ", err, msg.Payload)
} }
cr.TickerInforocessChan <- &ti cr.TickerInforocessChan <- &ti
continue
} }
// case "seriesInfo": // case "seriesInfo":
// { // {