Revert "test"

This reverts commit 3d3fc4e4fc.
2019-06-28 15:55:26 +08:00 · 2019-06-28 15:55:26 +08:00 · db0b7b7087
commit db0b7b7087
parent 38b611e7ca
1 changed files with 1 additions and 2 deletions
--- a/workers.go
+++ b/workers.go
@ -33,10 +33,9 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) {
 		}
 		//log.Printf("MQGetMsgWorker[" + strconv.Itoa(id) + "] : Connected to RabbitMQ")
 		log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Session address : %p.\n", &s)
-		log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Queue address : %p.\n", &s.MQQueue)
 		/*
 			m, err := s.MQChannel.Consume(
-				s.MQQueue.Name, // queue
+				s.Queue, // queue
 				"",      // consumer
 				true,    // auto-ack
 				false,   // exclusive