From 7f3202f35f6e9e353dd88b739fc4f941aef29c64 Mon Sep 17 00:00:00 2001
From: shoopea <shoopea@siteop.biz>
Date: Fri, 28 Jun 2019 16:27:19 +0800
Subject: [PATCH] test

---
 mq.go      | 2 +-
 workers.go | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/mq.go b/mq.go
index 9345fdf..c2722be 100644
--- a/mq.go
+++ b/mq.go
@@ -4,7 +4,7 @@ import (
 	"github.com/streadway/amqp"
 )
 
-func (c *MQClient) Open() error {
+func Open(c *MQClient) 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 273d7a6..66a8099 100644
--- a/workers.go
+++ b/workers.go
@@ -25,7 +25,7 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) {
 			SSL:      false,
 		}
 
-		err := c.Open()
+		err := Open(c)
 
 		if err != nil {
 			q, err := c.Channel.QueueDeclare(