From ddf0207ae339b5e157af94c5dbb2796051302547 Mon Sep 17 00:00:00 2001
From: shoopea <shoopea@siteop.biz>
Date: Fri, 28 Jun 2019 14:23:22 +0800
Subject: [PATCH] test

---
 def.go | 2 +-
 mq.go  | 9 ++++++---
 2 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/def.go b/def.go
index c0053a8..38f76f8 100644
--- a/def.go
+++ b/def.go
@@ -28,7 +28,7 @@ type MQSession struct {
 	Queue        string
 	MQConnection *amqp.Connection
 	MQChannel    *amqp.Channel
-	MQQueue      amqp.Queue
+	MQQueue      *amqp.Queue
 	MQDelivery   <-chan amqp.Delivery
 	isConnected  bool
 }
diff --git a/mq.go b/mq.go
index d1c25c6..f2764ab 100644
--- a/mq.go
+++ b/mq.go
@@ -14,7 +14,8 @@ func (s MQSession) Open() error {
 	}
 
 	if s.SSL == false {
-		s.MQConnection, err = amqp.Dial("amqp://" + s.User + ":" + s.Password + "@" + s.Host + "/" + s.Path)
+		conn, err := amqp.Dial("amqp://" + s.User + ":" + s.Password + "@" + s.Host + "/" + s.Path)
+		s.MQConnection = conn
 	} else {
 		return errors.New("SSL connection not implemented")
 	}
@@ -23,14 +24,15 @@ func (s MQSession) Open() error {
 		s.MQConnection.Close()
 		return err
 	}
-	s.MQChannel, err = s.MQConnection.Channel()
+	ch, err := s.MQConnection.Channel()
+	s.MQChannel = ch
 	logOnError(err, "Open : Failed to open channel")
 	if err != nil {
 		s.MQChannel.Close()
 		s.MQConnection.Close()
 		return err
 	}
-	s.MQQueue, err = s.MQChannel.QueueDeclare(
+	q, err := s.MQChannel.QueueDeclare(
 		s.Queue, // name
 		false,   // durable
 		false,   // delete when unused
@@ -39,6 +41,7 @@ func (s MQSession) Open() error {
 		nil,     // arguments
 
 	)
+	s.MQQueue = q
 	logOnError(err, "Open : Failed to declare queue")
 	if err != nil {
 		s.MQChannel.Close()