| | |
|---|
| | | 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)) |
|---|
| | | } |
|---|
| | |
|---|
| | | |
|---|
| | | 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)) |
|---|
