Update amqp-order-handler.go

2025-11-11 17:26:43 +01:00
parent a54435ebbb
commit 6d9f9bec11
1 changed files with 5 additions and 5 deletions
--- a/cmd/cart/amqp-order-handler.go
+++ b/cmd/cart/amqp-order-handler.go
@@ -27,7 +27,7 @@ func (h *AmqpOrderHandler) DefineTopics() error {
 	defer ch.Close()

 	queue, err := ch.QueueDeclare(
-		"orders", // name
+		"order-queue", // name
 		false,
 		false,
 		false,
@@ -51,10 +51,10 @@ func (h *AmqpOrderHandler) OrderCompleted(body []byte) error {
 	defer cancel()

 	return ch.PublishWithContext(ctx,
-		"",       // exchange
-		"orders", // routing key
-		false,    // mandatory
-		false,    // immediate
+		"",           // exchange
+		h.queue.Name, // routing key
+		false,        // mandatory
+		false,        // immediate
 		amqp.Publishing{
 			DeliveryMode: amqp.Persistent,
 			ContentType:  "application/json",