Commit cb73af4a authored by Lukas Burgey's avatar Lukas Burgey
Browse files

Bind to all services

Bind to both group and non-group services at the services exchange
parent e29aa019
......@@ -41,8 +41,12 @@ func (c *config) consumer() (cons *consumer) {
for _, service := range c.Services {
serviceRoutingKeys = append(serviceRoutingKeys, fmt.Sprintf("service.%s", service.Name))
}
for groupName := range c.GroupToServices {
for groupName, services := range c.GroupToServices {
groupRoutingKeys = append(groupRoutingKeys, fmt.Sprintf("%s", groupName))
for _, service := range services {
serviceRoutingKeys = append(serviceRoutingKeys, fmt.Sprintf("service.%s", service.Name))
}
}
cons = &consumer{
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment