test

2019-06-28 14:33:46 +08:00 · 2019-06-28 14:33:46 +08:00 · ea5eefec67
commit ea5eefec67
parent 020e2a5064
1 changed files with 7 additions and 7 deletions
--- a/workers.go
+++ b/workers.go
@ -34,7 +34,7 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) {
 		log.Printf("MQGetMsgWorker[" + strconv.Itoa(id) + "] : Connected to RabbitMQ")
 		log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Queue name : %s.\n", s.MQQueue.Name)
 		m, err := s.MQChannel.Consume(
-			s.MQQueue.Name, // queue
+			s.Queue, // queue
 			"",      // consumer
 			true,    // auto-ack
 			false,   // exclusive