From 68756d30b5818ebeb207b7a436964766f6673328 Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 28 Jun 2019 15:28:17 +0800 Subject: [PATCH] test --- workers.go | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 deletions(-) diff --git a/workers.go b/workers.go index d3bd41e..188c3bb 100644 --- a/workers.go +++ b/workers.go @@ -35,16 +35,17 @@ 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 : %s.\n", s.Queue) - /* - q, err := s.MQChannel.QueueDeclare( - s.Queue, // name - false, // durable - false, // delete when unused - false, // exclusive - false, // no-wait - nil, // arguments - ) + _, err := s.MQChannel.QueueDeclare( + s.Queue, // name + false, // durable + false, // delete when unused + false, // exclusive + false, // no-wait + nil, // arguments + + ) + /* m, err := s.MQChannel.Consume( q.Name, // queue "", // consumer