Added debug logging into seprate utils function

.gitignore

@@ -22,4 +22,5 @@ svault/
 !LICENSE
 
 # Ignore files
-checklist.md
+checklist.md
+Links.MD

Makefile

@@ -8,10 +8,10 @@ run:
 	go build && ./rabbitmq-benchmark
 
 run_p:
-	go build && ./rabbitmq-benchmark -t 1 -r producer -f 1000
+	go build && ./rabbitmq-benchmark -t 2 -r producer -debug -f 1000
 
 run_c:
-	go build && ./rabbitmq-benchmark -t 1 -r consumer -debug
+	go build && ./rabbitmq-benchmark -t 5 -r consumer -debug
 
 start_mq:
 	docker-compose up -d

queue/consumer.go

@@ -51,12 +51,10 @@ func ConsumerMQ(cfg utils.ConfigStore) {
 	for {
 		select {
 		case <-notify:
-			fmt.Println("Detects connection failuer, retring..")
+			log.Println("Detects connection failuer, retrying..")
 			ch, q, notify, msgs = failuerRetry(cfg)
 		case d = <-msgs:
-			if cfg.EnableDebug {
-				log.Printf("consumer message: %s\n", d.Body)
-			}
+			utils.DebugLogging(fmt.Sprintf("Consumer message:%s\n", d.Body), cfg.EnableDebug)
 			// Manual ack for consumed messages
 			d.Ack(false)
 		}
@@ -70,8 +68,9 @@ func failuerRetry(cfg utils.ConfigStore) (*amqp.Channel, amqp.Queue, chan *amqp.
 		if err != nil {
 			log.Println("Sleep 15 sec before retrying the publish")
 			time.Sleep(15 * time.Second)
+
 		} else {
-			fmt.Println("Reconnection is successful.")
+			log.Println("Reconnection is successful.")
 			msgs, _ := consumer(ch, q, cfg.EnableQuorum)
 			return ch, q, notify, msgs
 		}

queue/producer.go

@@ -11,7 +11,7 @@ import (
 )
 
 // publisher Publish messages
-func publisher(message string, ch *amqp.Channel, q amqp.Queue) error {
+func publisher(message string, ch *amqp.Channel, q amqp.Queue, endebug bool) error {
 
 	err := ch.Publish(
 		"",     // exchange
@@ -27,21 +27,23 @@ func publisher(message string, ch *amqp.Channel, q amqp.Queue) error {
 		return err
 	}
 
-	fmt.Println("published message: " + message)
+	utils.DebugLogging(fmt.Sprintf("published message: %s\n", message), endebug)
 
 	return nil
 }
 
 // PublishMQ worker func
 func PublishMQ(cfg utils.ConfigStore) {
+
 	ch, q, _, err := InitRabbitMQ(cfg.RabbitURL, cfg.QueueName, cfg.EnableQuorum)
 	if err != nil {
 		log.Fatalf("%s: %s", "Failed to publish a message", err)
 	}
+
 	for {
 		if (ch != nil && q != amqp.Queue{}) {
 			rand.Seed(time.Now().UnixNano())
-			err = publisher(utils.RandString(cfg.MsgSize), ch, q)
+			err = publisher(utils.RandString(cfg.MsgSize), ch, q, cfg.EnableDebug)
 			time.Sleep(time.Duration(cfg.TimeFrequencyMS) * time.Millisecond)
 		}
 

utils/logdebug.go

@@ -0,0 +1,10 @@
+package utils
+
+import "log"
+
+// DebugLogging helper func to log debug
+func DebugLogging(logstring string, enableDebug bool) {
+	if enableDebug {
+		log.Printf(logstring)
+	}
+}