From aadd432133262abb506fa0eb26092a864748b4ed Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 28 Jun 2019 15:54:29 +0800 Subject: [PATCH] Revert "test" This reverts commit c3a7017ed310d056dcce08c23a9c3505b196976d. --- workers.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/workers.go b/workers.go index 648c0aa..188c3bb 100644 --- a/workers.go +++ b/workers.go @@ -34,9 +34,9 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) { log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Session address : %p.\n", &s) 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 #1 : %s.\n", s.Queue) + log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Queue name : %s.\n", s.Queue) - q, err := s.MQChannel.QueueDeclare( + _, err := s.MQChannel.QueueDeclare( s.Queue, // name false, // durable false, // delete when unused @@ -45,7 +45,6 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) { nil, // arguments ) - log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Queue name #2 : %s.\n", q.Name) /* m, err := s.MQChannel.Consume( q.Name, // queue