From aca10f53a8bde6f45c1dbe3cc14de3b82ccf268a Mon Sep 17 00:00:00 2001 From: shoopea Date: Wed, 31 Jul 2019 15:30:02 +0800 Subject: [PATCH] debug client revamping --- workers.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/workers.go b/workers.go index d3dcc45..4818ec1 100644 --- a/workers.go +++ b/workers.go @@ -160,17 +160,17 @@ func MQKeepAliveWorker() { err = json.Unmarshal(d.Body, &x) logOnError(err, "MQKeepAliveWorker : Can't unmarshal.\n"+string(d.Body)) if err == nil { - log.Printf("MQKeepAliveWorker : Received message from %s", x.Nickname) + log.Printf("MQKeepAliveWorker : Received message from %s (%d).\n", x.Nickname, x.TGUserID64) if x.Date.Add(10 * time.Second).Before(time.Now()) { // outdated keep-alive coming from client } else if clt, ok := getLockedClient(x.TGUserID64, true); ok { clt.HeartBeat = x.Date if clt.Active { - log.Printf("MQKeepAliveWorker : Client %s already active.\n", clt.Login) + log.Printf("MQKeepAliveWorker : Client %s (%d) already active.\n", clt.Login, clt.TGUserID64) clt.Mux.Unlock() } else { clt.Login = x.Nickname - log.Printf("MQKeepAliveWorker : Connecting to %s.\n", clt.Login) + log.Printf("MQKeepAliveWorker : Connecting to %s (%d).\n", clt.Login, clt.TGUserID64) clt.MQ.User = cfg.Rabbit.User clt.MQ.Password = cfg.Rabbit.Password clt.MQ.Host = cfg.Rabbit.Host