Skip to content

Commit

Permalink
fix: remove app_id field from messagequeue config
Browse files Browse the repository at this point in the history
  • Loading branch information
shreddedbacon committed Apr 9, 2024
1 parent 6a802e9 commit 2d8266a
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 2 deletions.
2 changes: 1 addition & 1 deletion internal/broker/broker.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
}
1 change: 0 additions & 1 deletion main.go
Original file line number Diff line number Diff line change
Expand Up @@ -170,7 +170,6 @@ func main() {
Name: "lagoon-actions",
Exchange: "lagoon-actions",
Options: mq.Options{
"app_id": lagoonAppID,
"delivery_mode": "2",
"headers": "",
"content_type": "",
Expand Down

0 comments on commit 2d8266a

Please sign in to comment.