From 8cf2b415608f5b7a5bf9ca5db14c3aa1879ab4f9 Mon Sep 17 00:00:00 2001
From: shoopea <shoopea@siteop.biz>
Date: Fri, 28 Jun 2019 15:59:58 +0800
Subject: [PATCH] test

---
 chirpnest.sample.cfg | 2 +-
 workers.go           | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/chirpnest.sample.cfg b/chirpnest.sample.cfg
index 4e6eb9d..da10228 100644
--- a/chirpnest.sample.cfg
+++ b/chirpnest.sample.cfg
@@ -14,7 +14,7 @@ database   = chirpnest
 user	   = chirpnest
 password   = chirpnest
 host       = localhost:5672
-queue      = chirpnest
+path       = chirpnest
 
 [bot]
 admin      = 0
diff --git a/workers.go b/workers.go
index 3fc1764..afcf841 100644
--- a/workers.go
+++ b/workers.go
@@ -17,7 +17,7 @@ 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.Queue)
+		conn, err := amqp.Dial("amqp://" + cfg.Rabbit.User + ":" + cfg.Rabbit.Password + "@" + cfg.Rabbit.Host + "/" + cfg.Rabbit.Path)
 		logOnError(err, "MQGetMsgWorker["+strconv.Itoa(id)+"] : Failed to connect to RabbitMQ")
 		if err != nil {
 			conn.Close()
@@ -369,7 +369,7 @@ func MQTGCmdWorker(id int, cmds <-chan TGCommand) {
 func MQKeepAliveWorker() {
 	//log.Printf("MQKeepAliveWorker : Starting.")
 	for true {
-		conn, err := amqp.Dial("amqp://" + cfg.Rabbit.User + ":" + cfg.Rabbit.Password + "@" + cfg.Rabbit.Host + "/" + cfg.Rabbit.Queue)
+		conn, err := amqp.Dial("amqp://" + cfg.Rabbit.User + ":" + cfg.Rabbit.Password + "@" + cfg.Rabbit.Host + "/" + cfg.Rabbit.Path)
 		logOnError(err, "MQKeepAliveWorker : Failed to connect to RabbitMQ")
 		if err != nil {
 			conn.Close()