From 6a1e74bdc9ed84168ac7480fbf0b945bb61029d9 Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 14 Jun 2019 11:31:33 +0800 Subject: [PATCH] test --- client.go | 2 +- workers.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/client.go b/client.go index c1d7f33..5be4888 100644 --- a/client.go +++ b/client.go @@ -7,7 +7,7 @@ import ( ) func clientKeepAlive(k, v interface{}) bool { - clt := v.(MQKeepAlive) + clt := v.(*MQKeepAlive) if clt.Date.Add(2 * KeepAliveHeartBeatSeconds * time.Second).Before(time.Now()) { msgs, err := clientsQueue[clt.UserID64].Channel.QueuePurge(clientsQueue[clt.UserID64].Queue.Name, false) logOnError(err, "clientKeepAlive : Channel.QueuePurge()") diff --git a/workers.go b/workers.go index 668f6dd..86cfe02 100644 --- a/workers.go +++ b/workers.go @@ -385,7 +385,7 @@ func MQKeepAliveWorker() { if x.Date.Add(10 * time.Second).Before(time.Now()) { // outdated keep-alive coming from client } else if v, ok := clientsKeepAlive.Load(x.UserID64); ok { - k := v.(MQKeepAlive) + k := v.(*MQKeepAlive) k.Date = x.Date } else { clt := MQClient{}