diff --git a/internal/msggateway/client.go b/internal/msggateway/client.go index e6fdf7a39..9f612e021 100644 --- a/internal/msggateway/client.go +++ b/internal/msggateway/client.go @@ -136,6 +136,7 @@ func (c *Client) readMessage() { } switch messageType { case MessageBinary: + _ = c.conn.SetReadDeadline(pongWait) parseDataErr := c.handleMessage(message) if parseDataErr != nil { c.closedErr = parseDataErr