From 7a7e5640298714d4b81c3396d7705c08ed01b5af Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 28 Jun 2019 16:28:04 +0800 Subject: [PATCH] Revert "test" This reverts commit 7f3202f35f6e9e353dd88b739fc4f941aef29c64. --- mq.go | 2 +- workers.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/mq.go b/mq.go index c2722be..9345fdf 100644 --- a/mq.go +++ b/mq.go @@ -4,7 +4,7 @@ import ( "github.com/streadway/amqp" ) -func Open(c *MQClient) error { +func (c *MQClient) Open() error { var err error c.Connection, err = amqp.Dial("amqp://" + c.User + ":" + c.Password + "@" + c.Host + "/" + c.Path) diff --git a/workers.go b/workers.go index 66a8099..273d7a6 100644 --- a/workers.go +++ b/workers.go @@ -25,7 +25,7 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) { SSL: false, } - err := Open(c) + err := c.Open() if err != nil { q, err := c.Channel.QueueDeclare(