test

2019-06-28 16:19:26 +08:00 · 2019-06-28 16:19:26 +08:00 · 4a0618dcf5
commit 4a0618dcf5
parent 6b320ff0ee
1 changed files with 1 additions and 1 deletions
--- 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