From 64f9f086662989caf220821a182fde5a1f79c81b Mon Sep 17 00:00:00 2001
From: shoopea <shoopea@siteop.biz>
Date: Fri, 28 Jun 2019 16:04:52 +0800
Subject: [PATCH] test

---
 workers.go | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/workers.go b/workers.go
index afcf841..cd6cdbb 100644
--- a/workers.go
+++ b/workers.go
@@ -17,7 +17,16 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) {
 	//log.Printf("MQGetMsgWorker[" + strconv.Itoa(id) + "] : Starting.")
 	var x ChatWarsMessage
 	for true {
-		conn, err := amqp.Dial("amqp://" + cfg.Rabbit.User + ":" + cfg.Rabbit.Password + "@" + cfg.Rabbit.Host + "/" + cfg.Rabbit.Path)
+		c := MQClient{
+			User:     cfg.Rabbit.User,
+			Password: cfg.Rabbit.Password,
+			Host:     cfg.Rabbit.Host,
+			Path:     cfg.Rabbit.Path,
+			SSL:      false,
+		}
+
+		conn, err := amqp.Dial("amqp://" + c.User + ":" + c.Password + "@" + c.Host + "/" + c.Path)
+
 		logOnError(err, "MQGetMsgWorker["+strconv.Itoa(id)+"] : Failed to connect to RabbitMQ")
 		if err != nil {
 			conn.Close()