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

---
 workers.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/workers.go b/workers.go
index 81177c6..273d7a6 100644
--- a/workers.go
+++ b/workers.go
@@ -42,7 +42,7 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) {
 				c.Connection.Close()
 				time.Sleep(15 * time.Second)
 			} else {
-				m, err := ch.Consume(
+				m, err := c.Channel.Consume(
 					q.Name, // queue
 					"",     // consumer
 					true,   // auto-ack