From 7161c2a8b6355c474dfe6ffcdf201531892cb52c Mon Sep 17 00:00:00 2001 From: matst80 Date: Tue, 11 Nov 2025 16:00:59 +0100 Subject: [PATCH] Update amqp-order-handler.go --- cmd/cart/amqp-order-handler.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/cmd/cart/amqp-order-handler.go b/cmd/cart/amqp-order-handler.go index dddaac9..14e79e4 100644 --- a/cmd/cart/amqp-order-handler.go +++ b/cmd/cart/amqp-order-handler.go @@ -51,13 +51,14 @@ func (h *AmqpOrderHandler) OrderCompleted(body []byte) error { defer cancel() return ch.PublishWithContext(ctx, - "orders", // exchange - "new", // routing key + "", // exchange + "orders", // routing key false, // mandatory false, // immediate amqp.Publishing{ - ContentType: "application/json", - Body: body, + DeliveryMode: amqp.Persistent, + ContentType: "application/json", + Body: body, }) }