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