From 6885975ea049b3cf77a7f774e0aa134c9dd2f623 Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 28 Jun 2019 18:32:53 +0800 Subject: [PATCH] test --- workers.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/workers.go b/workers.go index c93be61..86840fb 100644 --- a/workers.go +++ b/workers.go @@ -238,7 +238,7 @@ func MQTGCmdWorker(id int, cmds <-chan TGCommand) { logOnError(err, "MQTGCmdWorker["+strconv.Itoa(id)+"] : Marshal(c)") //log.Printf("MQTGCmdWorker["+strconv.Itoa(id)+"] : new command.\n%s\n", string(j)) for clientsQueue[c.FromUserID64].Connection.IsClosed() { - clientsQueue[c.FromUserID64].Connection, err = amqp.Dial("amqp://" + c.User + ":" + c.Password + "@" + c.Host + "/" + c.Path) + clientsQueue[c.FromUserID64].Connection, err = amqp.Dial("amqp://" + clientsQueue[c.FromUserID64].User + ":" + clientsQueue[c.FromUserID64].Password + "@" + clientsQueue[c.FromUserID64].Host + "/" + clientsQueue[c.FromUserID64].Path) logOnError(err, "MQKeepAliveWorker : Cannot open MQ connection") if err != nil { clientsQueue[c.FromUserID64].Connection.Close()