diff --git a/app/worker.go b/app/worker.go index 6cdc7cc..d826385 100644 --- a/app/worker.go +++ b/app/worker.go @@ -191,7 +191,7 @@ func xWorker(workerData Info, u url.URL) { _, message, err := c.ReadMessage() if err != nil { fmt.Println(err.Error(), workerData.room) - if workerData.Income > 1 { + if workerData.Income > 1 && websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway) { go reconnectRoom(workerData) } return