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

---
 mq.go | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/mq.go b/mq.go
index 8fb1233..9345fdf 100644
--- a/mq.go
+++ b/mq.go
@@ -5,16 +5,15 @@ import (
 )
 
 func (c *MQClient) Open() error {
-	conn, err := amqp.Dial("amqp://" + c.User + ":" + c.Password + "@" + c.Host + "/" + c.Path)
-	c.Connection = conn
+	var err error
+	c.Connection, err = amqp.Dial("amqp://" + c.User + ":" + c.Password + "@" + c.Host + "/" + c.Path)
 
 	if err != nil {
 		c.Connection.Close()
 		return err
 	}
 
-	ch, err := c.Connection.Channel()
-	c.Channel = ch
+	c.Channel, err = c.Connection.Channel()
 	if err != nil {
 		c.Channel.Close()
 		c.Connection.Close()