接受 msg 解析 json 失败后，不再继续执行

c0efb4fc · xiaoguang.xu · 5f912a3e · c0efb4fc
Commit c0efb4fc authored Sep 24, 2019 by xiaoguang.xu
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 0 deletions

health_message_handler.go service/consumer/health_message_handler.go +1 -0

No files found.
--- a/service/consumer/health_message_handler.go
+++ b/service/consumer/health_message_handler.go
@@ -23,6 +23,7 @@ func (HealthMessageHandler) MsgProcess(msg string) {
 	if err != nil {
 		logger.Error.Println("healthMessageHandler解析json失败:", err)
 		logger.Error.Println(msg)
+		return
 	}
 	buildMsg(chunkMsg)
 }