diff --git a/app/worker.go b/app/worker.go index c493b0d..ecd8f6f 100644 --- a/app/worker.go +++ b/app/worker.go @@ -136,7 +136,7 @@ func getWS(workerData Info, key []byte) string { fmt.Println(err.Error()) return "" } - fmt.Println("send message!") + //fmt.Println("send message!") continue } @@ -249,6 +249,11 @@ func xWorker(workerData Info) { messageID := getMessageID(string(message)) + if messageID == 28 && strings.Contains(string(message), "offline") { + fmt.Println("offline:", workerData.room) + return + } + if messageID == 27 { input := struct { Value int64 `json:"value"`