From 2324caed49c45a0f4c2b1bfdc0079bba0a2c212c Mon Sep 17 00:00:00 2001
From: matst80 <mats.tornberg@gmail.com>
Date: Fri, 18 Apr 2025 18:24:17 +0200
Subject: [PATCH] connect to amqp

---
 main.go | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/main.go b/main.go
index e340b92..69a02a1 100644
--- a/main.go
+++ b/main.go
@@ -147,6 +147,7 @@ func main() {
 	orderHandler := &RabbitTransportMaster{
 		Url: amqpUrl,
 	}
+
 	syncedServer := NewPoolServer(syncedPool, fmt.Sprintf("%s, %s", name, podIp))
 	mux := http.NewServeMux()
 	mux.Handle("/cart/", http.StripPrefix("/cart", syncedServer.Serve()))
@@ -225,6 +226,14 @@ func main() {
 		if err != nil {
 			log.Printf("Error marshaling order: %v\n", err)
 		} else {
+			err = orderHandler.Connect()
+			if err != nil {
+				log.Printf("Error connecting to order handler: %v\n", err)
+				w.WriteHeader(http.StatusInternalServerError)
+				w.Write([]byte(err.Error()))
+				return
+			}
+			defer orderHandler.Close()
 			err = orderHandler.OrderCompleted(orderToSend)
 			if err != nil {
 				log.Printf("Error sending order: %v\n", err)