From f3b5ce2f14186b5b6daf4c0eda7027ddb6f83a57 Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 17 May 2019 16:14:23 +0800 Subject: [PATCH] test --- workers.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/workers.go b/workers.go index 2cb0190..1f10da5 100644 --- a/workers.go +++ b/workers.go @@ -326,8 +326,11 @@ func MQTidyKeepAliveWorker() { for _, v := range clientsKeepAlive { if v.Date.Add(90 * time.Second).Before(time.Now()) { msgs, err := clientsQueue[v.UserID64].Channel.QueuePurge(clientsQueue[v.UserID64].Queue.Name, false) - _ = clientsQueue[v.UserID64].Channel.Close() - _ = clientsQueue[v.UserID64].Connection.Close() + logOnError(err, "MQTidyKeepAliveWorker : Channel.QueuePurge()") + err = clientsQueue[v.UserID64].Channel.Close() + logOnError(err, "MQTidyKeepAliveWorker : Channel.Close()") + err = clientsQueue[v.UserID64].Connection.Close() + logOnError(err, "MQTidyKeepAliveWorker : Connection.Close()") c := TGCommand{ Type: commandSendMsg, ToUserID64: v.UserID64,