Skip to content
This repository has been archived by the owner on Feb 10, 2025. It is now read-only.

Commit

Permalink
fix: go fmt
Browse files Browse the repository at this point in the history
Signed-off-by: marcin.janas <[email protected]>
  • Loading branch information
marcin-janas committed Apr 5, 2022
1 parent fef9c81 commit d6af522
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions rabbitmq/consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -45,10 +45,10 @@ type workerParams struct {

// CreateConsumer creates consumer from string map
func CreateConsumer(entry config.RabbitEntry, rabbitConnector connector.RabbitConnector) consumer.Client {
// merge RoutingKey with RoutingKeys
if entry.RoutingKey != "" {
entry.RoutingKeys = append(entry.RoutingKeys, entry.RoutingKey)
}
// merge RoutingKey with RoutingKeys
if entry.RoutingKey != "" {
entry.RoutingKeys = append(entry.RoutingKeys, entry.RoutingKey)
}
return Consumer{entry.Name, entry.ConnectionURL, entry.ExchangeName, entry.QueueName, entry.RoutingKeys, rabbitConnector}
}

Expand Down

0 comments on commit d6af522

Please sign in to comment.