Revert "test"

This reverts commit 48ff558d59.
2019-06-28 15:54:42 +08:00 · 2019-06-28 15:54:42 +08:00 · 67fc40e7aa
commit 67fc40e7aa
parent ff8aa3b34d
1 changed files with 24 additions and 26 deletions
--- a/workers.go
+++ b/workers.go
@ -36,7 +36,6 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) {
 		log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Connection address : %p.\n", &s.MQConnection)
 		log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Channel address : %p.\n", &s.MQChannel)
 		log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Queue name : %s.\n", s.Queue)
-		/*
 		q, err := s.MQChannel.QueueDeclare(
 			s.Queue, // name
 			false,   // durable
@ -63,7 +62,6 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) {
 				msgs <- x
 			}
 		}
-		*/
 		log.Printf("MQGetMsgWorker[" + strconv.Itoa(id) + "] : Closing queue.\n")
 		s.Close()
 	}