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,