From 5223fef2fa2a9a3c310e0359d6dad6f3fbdd3ae2 Mon Sep 17 00:00:00 2001
From: matst80 <mats.tornberg@gmail.com>
Date: Tue, 11 Nov 2025 16:44:41 +0100
Subject: [PATCH] Update amqp-order-handler.go

---
 cmd/cart/amqp-order-handler.go | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/cmd/cart/amqp-order-handler.go b/cmd/cart/amqp-order-handler.go
index 14e79e4..972cbb9 100644
--- a/cmd/cart/amqp-order-handler.go
+++ b/cmd/cart/amqp-order-handler.go
@@ -9,7 +9,8 @@ import (
 )
 
 type AmqpOrderHandler struct {
-	conn *amqp.Connection
+	conn  *amqp.Connection
+	queue *amqp.Queue
 }
 
 func NewAmqpOrderHandler(conn *amqp.Connection) *AmqpOrderHandler {
@@ -25,19 +26,18 @@ func (h *AmqpOrderHandler) DefineTopics() error {
 	}
 	defer ch.Close()
 
-	err = ch.ExchangeDeclare(
+	queue, err := ch.QueueDeclare(
 		"orders", // name
-		"direct", // type
-		true,     // durable
-		false,    // auto-deleted
-		false,    // internal
-		false,    // no-wait
-		nil,      // arguments
+		false,
+		false,
+		false,
+		false,
+		nil,
 	)
 	if err != nil {
 		return fmt.Errorf("failed to declare an exchange: %w", err)
 	}
-
+	h.queue = &queue
 	return nil
 }