From 8cc253b797b6c22cb0841aedf638ff19dc197e79 Mon Sep 17 00:00:00 2001
From: gongshangguo <gongshangguo@admin.com>
Date: 星期二, 01 三月 2022 15:15:40 +0800
Subject: [PATCH] 写入消息锁
---
client/client.go | 3 ++-
1 files changed, 2 insertions(+), 1 deletions(-)
diff --git a/client/client.go b/client/client.go
index 7a2cbaf..3d6035b 100644
--- a/client/client.go
+++ b/client/client.go
@@ -209,6 +209,7 @@
return
}
err = c.Writer.Flush()
+ c.Logger.Debug("Write msg success...", zap.String("msg", string(bodyByte)))
if err != nil {
c.Logger.Error("Fail to write flush", zap.Error(err))
}
@@ -245,7 +246,7 @@
func (c *Client) WriteBody(body *aiot.Protocol) error {
body.Receiver = aiot.RECEIVER_TO_SAAS
- c.Logger.Debug("Send msg...", zap.Any("msg", body), zap.Any("msg", body), zap.Any("reqType", body.ReqType), zap.Any("msgType", body.MsgType))
+ c.Logger.Debug("Write Body...", zap.Any("msg", body), zap.Any("msg", body), zap.Any("reqType", body.ReqType), zap.Any("msgType", body.MsgType))
msgData, err := json.Marshal(body)
if err != nil {
c.Logger.Error("Fail to Marshal send data", zap.Error(err))
--
Gitblit v1.8.0