From e0d8afae925e9ec011b679ce8b48788c72fbe924 Mon Sep 17 00:00:00 2001 From: matst80 Date: Tue, 11 Nov 2025 17:27:05 +0100 Subject: [PATCH] change name --- cmd/cart/amqp-order-handler.go | 2 +- cmd/cart/checkout_server.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/cmd/cart/amqp-order-handler.go b/cmd/cart/amqp-order-handler.go index 0552c3e..7e2c274 100644 --- a/cmd/cart/amqp-order-handler.go +++ b/cmd/cart/amqp-order-handler.go @@ -19,7 +19,7 @@ func NewAmqpOrderHandler(conn *amqp.Connection) *AmqpOrderHandler { } } -func (h *AmqpOrderHandler) DefineTopics() error { +func (h *AmqpOrderHandler) DefineQueue() error { ch, err := h.conn.Channel() if err != nil { return fmt.Errorf("failed to open a channel: %w", err) diff --git a/cmd/cart/checkout_server.go b/cmd/cart/checkout_server.go index 3eac2a9..e44d251 100644 --- a/cmd/cart/checkout_server.go +++ b/cmd/cart/checkout_server.go @@ -42,7 +42,7 @@ func (a *App) HandleCheckoutRequests(amqpUrl string, mux *http.ServeMux, invento amqpListener.DefineTopics() a.pool.AddListener(amqpListener) orderHandler := NewAmqpOrderHandler(conn) - orderHandler.DefineTopics() + orderHandler.DefineQueue() mux.HandleFunc("/push", func(w http.ResponseWriter, r *http.Request) { log.Printf("Klarna order confirmation push, method: %s", r.Method)