From 8957a372d995f17fd5069416f9f528ad1c54e05f Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 28 Jun 2019 13:03:32 +0800 Subject: [PATCH] test --- client.go | 7 ++----- mq.go | 5 +++-- 2 files changed, 5 insertions(+), 7 deletions(-) diff --git a/client.go b/client.go index 2c5ccc3..6b6d690 100644 --- a/client.go +++ b/client.go @@ -9,12 +9,9 @@ import ( func clientKeepAlive(k, v interface{}) bool { clt := v.(*MQKeepAlive) 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].MQChannel.QueuePurge(clientsQueue[clt.UserID64].Queue.Name, false) logOnError(err, "clientKeepAlive : Channel.QueuePurge()") - err = clientsQueue[clt.UserID64].Channel.Close() - logOnError(err, "clientKeepAlive : Channel.Close()") - err = clientsQueue[clt.UserID64].Connection.Close() - logOnError(err, "clientKeepAlive : Connection.Close()") + clientsQueue[clt.UserID64].Close() c := TGCommand{ Type: commandSendMsg, ToUserID64: clt.UserID64, diff --git a/mq.go b/mq.go index 6ab4ae2..02fd9d0 100644 --- a/mq.go +++ b/mq.go @@ -7,12 +7,13 @@ import ( ) func (s MQSession) Open() error { + var err error if s.isConnected { return errors.New("Session is already connected.") } - if SLL == false { - s.MQConnection, err = amqp.Dial("amqp://" + Session.User + ":" + Session.Password + "@" + Session.Host + "/" + Session.Path) + if SSL == false { + s.MQConnection, err = amqp.Dial("amqp://" + s.User + ":" + s.Password + "@" + s.Host + "/" + s.Path) } else { return errors.New("SSL connection not implemented") }