Skip to content

Commit

Permalink
Added support for optional rabbitmq.
Browse files Browse the repository at this point in the history
  • Loading branch information
r-franke committed Jun 23, 2021
1 parent 31d339a commit 48a08d7
Showing 1 changed file with 12 additions and 0 deletions.
12 changes: 12 additions & 0 deletions main.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@ import (

type Env struct {
AppName string
RMQ string
Vars map[string]string
}

Expand Down Expand Up @@ -69,6 +70,17 @@ func loadHaasEnvironment(requested Requested) Env {
env.Vars[req.Key] = value
}

rabbitVars, err := appEnv.Services.WithLabel("p.rabbitmq")
if err != nil {
return env
}
InfoLogger.Println("Rabbitmq found, connectionstring available under env.RMQ ")
if len(rabbitVars) > 1 {
InfoLogger.Println("Multiple Rabbit bindings discovered. Loading first one by default.")
}
credentials := rabbitVars[0].Credentials
env.RMQ = credentials["uri"].(string)

return env
}

Expand Down

0 comments on commit 48a08d7

Please sign in to comment.