From 9aa886de9a8da5d8c2fcc065f4f09e87ddc712a9 Mon Sep 17 00:00:00 2001
From: RuisPipe <alexander@roese.dev>
Date: Sun, 1 Aug 2021 22:09:40 +0200
Subject: [PATCH] Added Qos support

---
 modules/rabbitmq/rabbitmq.go | 18 +++++++++++++-----
 1 file changed, 13 insertions(+), 5 deletions(-)

diff --git a/modules/rabbitmq/rabbitmq.go b/modules/rabbitmq/rabbitmq.go
index 93e1e1c..500fd62 100644
--- a/modules/rabbitmq/rabbitmq.go
+++ b/modules/rabbitmq/rabbitmq.go
@@ -42,11 +42,19 @@ func Init() {
 		log.Fatalln("Failed to open a channel", err)
 	}
 
-	defer ch.Close()
+	//defer ch.Close()
 
 	Channel = ch
 
-	log.Debug("RabbitMQ connected")
+	err = ch.Qos(
+		1,     // prefetch count
+		0,     // prefetch size
+		false, // global
+	)
+
+	if err != nil {
+		log.Fatalln("Failed to set QoS", err)
+	}
 
 	msgs, err := ch.Consume(
 		"mails", // queue
@@ -66,7 +74,7 @@ func Init() {
 
 	go func() {
 		for d := range msgs {
-			fmt.Printf("Recieved Message: %s\n", d.Body)
+			log.Debugf("Recieved Message: %s\n", d.Body)
 
 			log.Info("aa")
 
@@ -84,7 +92,7 @@ func Init() {
 		}
 	}()
 
-	fmt.Println("Successfully Connected to our RabbitMQ Instance")
-	fmt.Println(" [*] - Waiting for messages")
+	log.Info("Successfully Connected to our RabbitMQ Instance")
+	log.Debug(" [*] - Waiting for messages")
 	<-forever
 }