fix nats subject map for endpoint

unusualcodeorg · Jul 1, 2024 · 973e598 · 973e598
1 parent 8803d28
commit 973e598
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/arch/micro/router.go b/arch/micro/router.go
@@ -43,7 +43,11 @@ func (r *router) LoadControllers(controllers []Controller) {
 	natsClient := r.natsClient.GetInstance()
 
 	for _, c := range controllers {
-		baseSub := fmt.Sprintf(`%s.%s`, natsClient.Service.Info().Name, strings.ReplaceAll(c.Path(), "/", ""))
+		baseSub := natsClient.Service.Info().Name
+		endpoint := strings.ReplaceAll(c.Path(), "/", ".")
+		if len(endpoint) > 1 {
+			baseSub = fmt.Sprintf(`%s%s`, baseSub, endpoint)
+		}
 
 		ng := natsClient.Service.AddGroup(baseSub)
 		c.MountNats(ng)