From 1e17576004d16215f35010194ef8107498a5e279 Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 14 Jun 2019 12:54:09 +0800 Subject: [PATCH] test --- client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client.go b/client.go index 5be4888..d93fb6e 100644 --- a/client.go +++ b/client.go @@ -8,7 +8,7 @@ import ( func clientKeepAlive(k, v interface{}) bool { clt := v.(*MQKeepAlive) - if clt.Date.Add(2 * KeepAliveHeartBeatSeconds * time.Second).Before(time.Now()) { + if clt.Date.Add(3 * KeepAliveHeartBeatSeconds * time.Second).Before(time.Now()) { msgs, err := clientsQueue[clt.UserID64].Channel.QueuePurge(clientsQueue[clt.UserID64].Queue.Name, false) logOnError(err, "clientKeepAlive : Channel.QueuePurge()") err = clientsQueue[clt.UserID64].Channel.Close()