test
This commit is contained in:
parent
a2befac211
commit
1e17576004
@ -8,7 +8,7 @@ import (
|
|||||||
|
|
||||||
func clientKeepAlive(k, v interface{}) bool {
|
func clientKeepAlive(k, v interface{}) bool {
|
||||||
clt := v.(*MQKeepAlive)
|
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)
|
msgs, err := clientsQueue[clt.UserID64].Channel.QueuePurge(clientsQueue[clt.UserID64].Queue.Name, false)
|
||||||
logOnError(err, "clientKeepAlive : Channel.QueuePurge()")
|
logOnError(err, "clientKeepAlive : Channel.QueuePurge()")
|
||||||
err = clientsQueue[clt.UserID64].Channel.Close()
|
err = clientsQueue[clt.UserID64].Channel.Close()
|
||||||
|
Loading…
Reference in New Issue
Block a user