From 81c7b10291b128f13e5eebcfaf4054be05e34764 Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 28 Jun 2019 15:54:57 +0800 Subject: [PATCH] Revert "test" This reverts commit 80b402777676ba872759ce52e689131ffbc27ccf. --- workers.go | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/workers.go b/workers.go index 8331a68..b3f3d93 100644 --- a/workers.go +++ b/workers.go @@ -33,8 +33,7 @@ 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)+"] : 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 address : %p.\n", &s.MQQueue) log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Queue name : %s.\n", s.Queue) q, err := s.MQChannel.QueueDeclare( s.Queue, // name @@ -89,8 +88,6 @@ func MQKeepAliveWorker() { } //log.Printf("MQKeepAliveWorker : Connected to RabbitMQ") log.Printf("MQKeepAliveWorker : Session address : %p.\n", &s) - log.Printf("MQKeepAliveWorker : Connection address : %p.\n", &s.MQConnection) - log.Printf("MQKeepAliveWorker : Channel address : %p.\n", &s.MQChannel) q, err := s.MQChannel.QueueDeclare( s.Queue, // name false, // durable