From 2e90cdcfeac5b78957ae0d2fe47da7502d60cb72 Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 28 Jun 2019 15:30:09 +0800 Subject: [PATCH] test --- workers.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/workers.go b/workers.go index 648c0aa..60a501c 100644 --- a/workers.go +++ b/workers.go @@ -35,8 +35,9 @@ 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) + ch := s.MQChannel - q, err := s.MQChannel.QueueDeclare( + q, err := ch.QueueDeclare( s.Queue, // name false, // durable false, // delete when unused