This commit is contained in:
shoopea 2019-07-31 15:01:32 +08:00
parent e5b476e406
commit c5829065c0

View File

@ -168,6 +168,7 @@ func MQKeepAliveWorker() {
if clt.Active {
clt.Mux.Unlock()
} else {
log.Printf("MQKeepAliveWorker : Connecting client.\n")
clt.MQ = MQClient{
User: cfg.Rabbit.User,
Password: cfg.Rabbit.Password,