From 321e359f84f0a7b4b76c1cb2c3739295668254d4 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?H=C3=A5vard=20Elnan?= <havard.elnan@nhn.no>
Date: Mon, 10 Feb 2025 21:10:56 +0100
Subject: [PATCH] create queue once

---
 .../rabbitmq_definitions_api.go               | 28 -------------------
 .../api_rabbitmq_handler.go                   | 18 ++++++------
 2 files changed, 10 insertions(+), 36 deletions(-)

diff --git a/internal/rabbitmq/apirabbitmqdefinitions/rabbitmq_definitions_api.go b/internal/rabbitmq/apirabbitmqdefinitions/rabbitmq_definitions_api.go
index 8ff95fb..baa76a8 100644
--- a/internal/rabbitmq/apirabbitmqdefinitions/rabbitmq_definitions_api.go
+++ b/internal/rabbitmq/apirabbitmqdefinitions/rabbitmq_definitions_api.go
@@ -97,7 +97,6 @@ func init() {
 // It is called from the main function
 // and it is blocking
 func InitOrDie() {
-	queueArgs := amqp091.Table{}
 
 	err := apiconnections.RabbitMQConnection.GetChannel().ExchangeDeclare(
 		messagebuscontracts.ExchangeRor, // name
@@ -165,31 +164,4 @@ func InitOrDie() {
 	if err != nil {
 		panic(err)
 	}
-
-	ApiEventsqueue, err = apiconnections.RabbitMQConnection.GetChannel().QueueDeclare(
-		ApiEventsQueueName, // name
-		true,               // durable
-		true,               // delete when unused
-		false,              // exclusive
-		false,              // no-wait
-		queueArgs,          // arguments, non quorum queue
-	)
-	if err != nil {
-		args := [...]any{ApiEventsQueueName, err}
-		msg := fmt.Sprintf("could not declare exchange  %s,", args)
-		rlog.Fatal(msg, err)
-	}
-
-	err = apiconnections.RabbitMQConnection.GetChannel().QueueBind(
-		ApiEventsQueueName,                    // queue name
-		"",                                    // routing key
-		messagebuscontracts.ExchangeRorEvents, // exchange
-		false,
-		nil,
-	)
-	if err != nil {
-		args := [...]any{ApiEventsQueueName, err}
-		msg := fmt.Sprintf("could not bind queue  %s,", args)
-		rlog.Fatal(msg, err)
-	}
 }
diff --git a/internal/rabbitmq/apirabbitmqhandler/api_rabbitmq_handler.go b/internal/rabbitmq/apirabbitmqhandler/api_rabbitmq_handler.go
index 4d49ab5..5804415 100644
--- a/internal/rabbitmq/apirabbitmqhandler/api_rabbitmq_handler.go
+++ b/internal/rabbitmq/apirabbitmqhandler/api_rabbitmq_handler.go
@@ -21,14 +21,16 @@ import (
 func StartListening() {
 	go func() {
 		config := rabbitmqhandler.RabbitMQListnerConfig{
-			Client:    apiconnections.RabbitMQConnection,
-			QueueName: apirabbitmqdefinitions.ApiEventsQueueName,
-			Consumer:  "",
-			AutoAck:   false,
-			Exclusive: false,
-			NoLocal:   false,
-			NoWait:    false,
-			Args:      nil,
+			Client:          apiconnections.RabbitMQConnection,
+			QueueName:       apirabbitmqdefinitions.ApiEventsQueueName,
+			Consumer:        "",
+			AutoAck:         false,
+			Exclusive:       false,
+			NoLocal:         false,
+			NoWait:          false,
+			Args:            nil,
+			QueueAutoDelete: true,
+			Exchange:        messagebuscontracts.ExchangeRorEvents,
 		}
 		rabbithandler := rabbitmqhandler.New(config, apimessagehandler{})
 		_ = apiconnections.RabbitMQConnection.RegisterHandler(rabbithandler)