From db0b7b7087366afe92d8bd99b6cf235576814307 Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 28 Jun 2019 15:55:26 +0800 Subject: [PATCH] Revert "test" This reverts commit 3d3fc4e4fcb2851fe75d6a6158e71678d22c8d04. --- workers.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/workers.go b/workers.go index c31dce4..88e2df3 100644 --- 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