From d5ff9a9c4eb04db170e18ab014d4c7ed4ea5fa45 Mon Sep 17 00:00:00 2001 From: shoopea Date: Wed, 31 Jul 2019 15:06:16 +0800 Subject: [PATCH] debug --- workers.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/workers.go b/workers.go index 9fbe2dd..554fc47 100644 --- a/workers.go +++ b/workers.go @@ -166,10 +166,10 @@ func MQKeepAliveWorker() { } else if clt, ok := getLockedClient(x.TGUserID64, true); ok { clt.HeartBeat = x.Date if clt.Active { - log.Printf("MQKeepAliveWorker : Client already active.\n") + log.Printf("MQKeepAliveWorker : Client %s already active.\n", x.Nickname) clt.Mux.Unlock() } else { - log.Printf("MQKeepAliveWorker : Connecting client.\n") + log.Printf("MQKeepAliveWorker : Connecting to %s.\n", x.Nickname) clt.MQ = MQClient{ User: cfg.Rabbit.User, Password: cfg.Rabbit.Password, @@ -202,6 +202,7 @@ func MQKeepAliveWorker() { clt.MQ.Connection.Close() } else { clt.Active = true + log.Printf("MQKeepAliveWorker : Connected to %s.\n", x.Nickname) } } }