From 6d9f9bec1178aa0dac3fd0d3aa50cbbde707f33c Mon Sep 17 00:00:00 2001 From: matst80 Date: Tue, 11 Nov 2025 17:26:43 +0100 Subject: [PATCH] Update amqp-order-handler.go --- cmd/cart/amqp-order-handler.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/cmd/cart/amqp-order-handler.go b/cmd/cart/amqp-order-handler.go index 972cbb9..0552c3e 100644 --- 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",