json 配置文件修复

2024-12-17 00:05:15 +08:00 · 2024-12-17 00:05:15 +08:00 · bf32c61096
commit bf32c61096
parent a55880827d
1 changed files with 2 additions and 2 deletions
--- a/modules/extent.go
+++ b/modules/extent.go
@ -90,8 +90,8 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi
 		} else {
 			logrus.Warning("channelname not match", channelName)
 		}
-		// logrus.Warning("msg.Payload: ", msg.Payload)
-		// fmt.Println("channelName: ", channelName, " msg.Payload: ", msg.Payload)
+		logrus.Warning("msg.Payload: ", msg.Payload)
+		fmt.Println("channelName: ", channelName, " msg.Payload: ", msg.Payload)
 		switch ctype {
 		// 接收到的candle扔到 candle 二次加工流水线
 		case "candle":