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

modules/extent.go

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