From 4a161936668d574c86a3c46d1f2b19d2760721f3 Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 17 May 2019 15:07:47 +0800 Subject: [PATCH] test --- workers.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/workers.go b/workers.go index 1d3d849..3ef3d01 100644 --- a/workers.go +++ b/workers.go @@ -287,18 +287,18 @@ func MQTidyKeepAliveWorker() { log.Printf("MQTidyKeepAliveWorker : Starting.") for true { t := time.Now() - for k, v := range clientsQueues { + for _, v := range clientsQueues { if v.Date.Add(90 * time.Second).Before(time.Now()) { c := TGCommand{ Type: commandSendMsg, - ToChatID64: x.UserID64, + ToChatID64: v.UserID64, Text: "Timeout.", } TGCmdQueue <- c - delete(clientsQueues, x.UserID64) + delete(clientsQueues, v.UserID64) } } - time.Sleep(time.Until(t.Add(time.Minute))) + time.Sleep(time.Until(t.Add(time.Second))) } log.Printf("MQTidyKeepAliveWorker : Closing.") }