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":  "",