Derive routing key from MQTT publisher

rabbitmq · Sep 27, 2024 · 7edeeca · 7edeeca
1 parent 52f7d7a
commit 7edeeca
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/mgmt/mgmt.go b/pkg/mgmt/mgmt.go
@@ -61,6 +61,7 @@ func DeclareAndBind(cfg config.Config, queue string, id int) rmq.IQueueInfo {
 	var exchangeName, routingKey string
 	if cfg.PublisherProto == config.MQTT {
 		exchangeName = "amq.topic"
+		routingKey = utils.InjectId(cfg.PublishTo, id)
 	} else {
 		exchangeName, routingKey = parsePublishTo(cfg.PublishTo, id)
 	}