From cfdf86ccc4dda26f56189ac7742df2e4de11bb4e Mon Sep 17 00:00:00 2001 From: Monet Lee Date: Wed, 17 Jul 2024 17:29:35 +0800 Subject: [PATCH] update pingHandler method send args. --- internal/msggateway/client.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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)) }