diff --git a/pkg/mgmt/mgmt.go b/pkg/mgmt/mgmt.go
index 0c2efe7..5cbb539 100644
--- 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)
 	}