diff --git a/workers.go b/workers.go
index d2f8f77..3fc1764 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("amqps://" + 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.Queue)
 		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("amqps://" + 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.Queue)
 		logOnError(err, "MQKeepAliveWorker : Failed to connect to RabbitMQ")
 		if err != nil {
 			conn.Close()