From 42b64c08be7dc0f646a5fd8a6f836b084bf6c10c Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 28 Jun 2019 15:54:17 +0800 Subject: [PATCH] Revert "test" This reverts commit ea3eeb38f6b6421407dada4260d6bfccaa12765e. --- mq.go | 3 +-- workers.go | 1 - 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/mq.go b/mq.go index 70748c0..b4d1264 100644 --- a/mq.go +++ b/mq.go @@ -2,7 +2,7 @@ package main import ( "errors" - "log" + //"log" "github.com/streadway/amqp" ) @@ -37,7 +37,6 @@ func (s MQSession) Open() error { s.MQConnection.Close() return err } - log.Printf("Open : IsClosed : %t\n", s.MQConnection.IsClosed()) /* q, err = s.MQChannel.QueueDeclare( s.Queue, // name diff --git a/workers.go b/workers.go index 9d1dac9..60a501c 100644 --- a/workers.go +++ b/workers.go @@ -35,7 +35,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 #1 : %s.\n", s.Queue) - log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : IsClosed : %t.\n", s.MQConnection.IsClosed()) ch := s.MQChannel q, err := ch.QueueDeclare(