From ac2ae044f624a5ae56caa78a020fcfdf9b2bd72a Mon Sep 17 00:00:00 2001
From: shoopea <shoopea@siteop.biz>
Date: Fri, 28 Jun 2019 15:56:14 +0800
Subject: [PATCH] Revert "test"

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

diff --git a/mq.go b/mq.go
index 5c64616..a5298d9 100644
--- a/mq.go
+++ b/mq.go
@@ -8,18 +8,13 @@ import (
 )
 
 func (s MQSession) Open() error {
-	var (
-		err  error
-		conn *amqp.Connection
-		ch   *amqp.Channel
-		q    *amqp.Queue
-	)
+	var err error
 	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")
@@ -29,7 +24,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 {
@@ -37,7 +32,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