From ef03a4dad4772f1cef98236628c95c5840a22e90 Mon Sep 17 00:00:00 2001
From: shoopea <shoopea@siteop.biz>
Date: Fri, 28 Jun 2019 17:19:17 +0800
Subject: [PATCH] test

---
 workers.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/workers.go b/workers.go
index 4de2999..84d7c42 100644
--- a/workers.go
+++ b/workers.go
@@ -47,6 +47,7 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) {
 
 		log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Address of struct : %p\n", &c)
 		err := OpenMQ(&c)
+		logOnError(err, "MQGetMsgWorker["+strconv.Itoa(id)+"] : Cannot open MQ connection")
 
 		if err != nil {
 			q, err := c.Channel.QueueDeclare(
@@ -92,6 +93,7 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) {
 			}
 
 		}
+
 	}
 
 	log.Printf("MQGetMsgWorker[" + strconv.Itoa(id) + "] : Closing.")