diff --git a/handler/im.go b/handler/im.go
index 1719a19..e7a1911 100644
--- a/handler/im.go
+++ b/handler/im.go
@@ -99,6 +99,7 @@ func subscribeAndHandleIMMessages(ws *websocket.Conn, userId int) {
 			log.Println("rec message:", string(message))
 			if err != nil {
 				log.Println("Read error:", err)
+				break
 			}
 			var data proto.WSMessage
 			err1 := json.Unmarshal(message, &data)