diff --git a/internal/msggateway/client.go b/internal/msggateway/client.go index 231e03473..2d898ff45 100644 --- a/internal/msggateway/client.go +++ b/internal/msggateway/client.go @@ -103,7 +103,7 @@ func (c *Client) pingHandler(appData string) error { log.ZDebug(c.ctx, "ping Handler Success.", "appData", appData) - return c.writePongMsg() + return c.writePongMsg(appData) } func (c *Client) pongHandler(_ string) error { @@ -158,7 +158,7 @@ func (c *Client) readMessage() { return case PingMessage: - err := c.writePongMsg() + err := c.writePongMsg("") log.ZError(c.ctx, "writePongMsg", err) case CloseMessage: @@ -380,7 +380,7 @@ func (c *Client) writePingMsg() error { return c.conn.WriteMessage(PingMessage, nil) } -func (c *Client) writePongMsg() error { +func (c *Client) writePongMsg(appData string) error { if c.closed.Load() { return nil } @@ -393,5 +393,5 @@ func (c *Client) writePongMsg() error { return err } - return c.conn.WriteMessage(PongMessage, nil) + return c.conn.WriteMessage(PongMessage, []byte(appData)) }