Revert "test"

This reverts commit ea5eefec67.
2019-06-28 15:55:58 +08:00 · 2019-06-28 15:55:58 +08:00 · 5887fee908
commit 5887fee908
parent 187b90c085
1 changed files with 7 additions and 7 deletions
--- a/workers.go
+++ b/workers.go
@ -34,13 +34,13 @@ 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.Queue, // queue
-			"",      // consumer
-			true,    // auto-ack
-			false,   // exclusive
-			false,   // no-local
-			false,   // no-wait
-			nil,     // args
+			s.MQQueue.Name, // queue
+			"",             // consumer
+			true,           // auto-ack
+			false,          // exclusive
+			false,          // no-local
+			false,          // no-wait
+			nil,            // args
 		)
 		for d := range m {
 			log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Received a message: %s", string(d.Body))