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{}