change name
This commit is contained in:
@@ -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)
|
||||
|
||||
@@ -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)
|
||||
|
||||
Reference in New Issue
Block a user