client/client.go
@@ -6,6 +6,7 @@ "bufio" "encoding/binary" "encoding/json" "errors" uuid "github.com/satori/go.uuid" "go.uber.org/zap" "io" @@ -239,6 +240,12 @@ c.Logger.Error("Write Body Error:", err) } }() if c.IsClosed() { errMsg := "Can not write msg into closed chain" c.Logger.Warn(errMsg, zap.Any("msg",body)) return errors.New(errMsg) } body.Receiver = aiot.RECEIVER_TO_SAAS msgData, err := json.Marshal(body) if err != nil {
