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

---
 mq.go | 13 +++++++++----
 1 file changed, 9 insertions(+), 4 deletions(-)

diff --git a/mq.go b/mq.go
index a5298d9..5c64616 100644
--- a/mq.go
+++ b/mq.go
@@ -8,13 +8,18 @@ import (
 )
 
 func (s MQSession) Open() error {
-	var err error
+	var (
+		err  error
+		conn *amqp.Connection
+		ch   *amqp.Channel
+		q    *amqp.Queue
+	)
 	if s.isConnected {
 		return errors.New("Session is already connected.")
 	}
 
 	if s.SSL == false {
-		conn, 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")
@@ -24,7 +29,7 @@ func (s MQSession) Open() error {
 		s.MQConnection.Close()
 		return err
 	}
-	ch, err := s.MQConnection.Channel()
+	ch, err = s.MQConnection.Channel()
 	s.MQChannel = ch
 	logOnError(err, "Open : Failed to open channel")
 	if err != nil {
@@ -32,7 +37,7 @@ func (s MQSession) Open() error {
 		s.MQConnection.Close()
 		return err
 	}
-	q, err := s.MQChannel.QueueDeclare(
+	q, err = s.MQChannel.QueueDeclare(
 		s.Queue, // name
 		false,   // durable
 		false,   // delete when unused