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, }) }