fix: add prefix to exchanges

2022-09-30 09:35:29 +02:00 · 2022-09-30 09:35:29 +02:00 · 919d1d0c11
commit 919d1d0c11
parent 0da01cf6b7
1 changed files with 3 additions and 2 deletions
--- a/cmd/twhelp/internal/watermill.go
+++ b/cmd/twhelp/internal/watermill.go
@ -51,10 +51,11 @@ func newAMQPConfig(generateQueueName amqp.QueueNameGenerator) (amqp.Config, erro
 	}

 	cfg := amqp.NewDurablePubSubConfig(appCfg.URI, generateQueueName)
-
 	cfg.Consume.NoRequeueOnNack = true
 	cfg.Consume.Qos.PrefetchCount = appCfg.PrefetchCount
-
+	cfg.Exchange.GenerateName = func(topic string) string {
+		return "twhelp_" + topic
+	}
 	return cfg, nil
 }