From 2d8266af7b8e3960d5431afed3827133a543fa2a Mon Sep 17 00:00:00 2001
From: shreddedbacon <b@benjackson.email>
Date: Tue, 9 Apr 2024 11:13:54 +1000
Subject: [PATCH] fix: remove app_id field from messagequeue config

---
 internal/broker/broker.go | 2 +-
 main.go                   | 1 -
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git a/internal/broker/broker.go b/internal/broker/broker.go
index 5674340..13f1c60 100644
--- a/internal/broker/broker.go
+++ b/internal/broker/broker.go
@@ -40,6 +40,6 @@ func (h *MQ) Publish(queue string, message []byte) error {
 		opLog.Info(fmt.Sprintf("Failed to get async producer: %v", err))
 		return err
 	}
-	producer.Produce([]byte(fmt.Sprintf("%s", message)))
+	producer.Produce(message)
 	return nil
 }
diff --git a/main.go b/main.go
index c6ec064..565a6c0 100644
--- a/main.go
+++ b/main.go
@@ -170,7 +170,6 @@ func main() {
 				Name:     "lagoon-actions",
 				Exchange: "lagoon-actions",
 				Options: mq.Options{
-					"app_id":        lagoonAppID,
 					"delivery_mode": "2",
 					"headers":       "",
 					"content_type":  "",