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

---
 def.go     | 2 +-
 workers.go | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/def.go b/def.go
index 38f76f8..c0053a8 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/workers.go b/workers.go
index b049fdf..a7f16c1 100644
--- a/workers.go
+++ b/workers.go
@@ -316,13 +316,13 @@ func MQTGCmdWorker(id int, cmds <-chan TGCommand) {
 		logOnError(err, "MQTGCmdWorker["+strconv.Itoa(id)+"] : Marshal(c)")
 
 		if clientIsAlive(c.FromUserID64) {
-			err = clientsQueue[c.FromUserID64].Publish("application/json", j)
+			err = clientsQueue[c.FromUserID64].Publish("application/json", string(j))
 			logOnError(err, "MQTGCmdWorker["+strconv.Itoa(id)+"] : Publishing message.")
 			for err != nil && clientIsAlive(c.FromUserID64) {
 				clientsQueue[c.FromUserID64].Close()
 				time.Sleep(5 * time.Second)
 				clientsQueue[c.FromUserID64].Open()
-				err = clientsQueue[c.FromUserID64].Publish("application/json", j)
+				err = clientsQueue[c.FromUserID64].Publish("application/json", string(j))
 			}
 		} else {
 			err = nil